----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/55705/ -----------------------------------------------------------
Review request for Flume. Repository: flume-git Description ------- There are several method call in kafka sink with no timeout params, in some cases, kafka sink will await forever if no interruption. Diffs ----- flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java 241e900 flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java 7c819f5 Diff: https://reviews.apache.org/r/55705/diff/ Testing ------- All tests passed Thanks, deng kai
