----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/37102/ -----------------------------------------------------------
Review request for samza. Bugs: SAMZA-753 https://issues.apache.org/jira/browse/SAMZA-753 Repository: samza Description ------- shutdown the kafka consumer before interrupting the BrokerProxy Diffs ----- samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala 614f33f Diff: https://reviews.apache.org/r/37102/diff/ Testing ------- Thanks, Yan Fang