[Sprint 39] [master] XD-2333 Add Kafka integration test

  - Add kafka test support class that checks for kafka server availablity on localhost
     - This uses zk server available on default connect string `localhost:2181`
  - Add test for verifying kafka source and sink
     - having both the source/sink on the same test case will make sure the topic that
gets the data by kafka sink is actually read by kafka source
yeah, they all can be avoided, originally I added to work around the time out issue on kafka source. But, now I fixed it by having a larger `consumerTimeout`. will be removing all the explicit thread sleep now.