@Test(expected = IllegalStateException.class) public void testMissingBrokerString() {
    new SimpleKafkaWriter("t",
        null, new Properties());
  }
Test class for Kafka simple writer.
kafka-handler/src/test/org/apache/hadoop/hive/kafka/SimpleKafkaWriterTest.java