I suspect there is a resource leak in the below code ... just wanted to confirm before filing a jira..
https://github.com/apache/flume/blob/e8c4a7bffc74f6ea10ae6cc45adbaf4919f45186/flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java#L128-L133 I am thinking a zkUtils.close() is needed at the end of that method.
