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.
---