Github user akumarb2010 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1027#discussion_r150376586
--- Diff:
contrib/storage-kafka/src/test/java/org/apache/drill/exec/store/kafka/cluster/EmbeddedZKQuorum.java
---
@@ -0,0 +1,83 @@
+/**
--- End diff --
This is taken care.---
