@Before public void setUp() {
    LOG.info("setting up Config");
    setupConsumer();
  }
Test class for Kafka simple writer.
kafka-handler/src/test/org/apache/hadoop/hive/kafka/SimpleKafkaWriterTest.java