@Test
public void testOutputKafka_noBrokerList() throws Exception {

  LOG.info("testOutputKafka_noBrokerList()");
  expectedException.expect(Exception.class);
  expectedException.expectMessage("For kafka output, bootstrap broker_list is needed");
  Map<String, Object> config = new HashMap<String, Object>();
  config.put("topic", TEST_TOPIC);
  outputKafka.loadConfig(config);
  outputKafka.init();
}