-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32084/
-----------------------------------------------------------
Review request for Flume.
Bugs: FLUME-2632
https://issues.apache.org/jira/browse/FLUME-2632
Repository: flume-git
Description
-------
Added backoff when channel is empty and added counters
Diffs
-----
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
eada17c
flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java
80f764f
Diff: https://reviews.apache.org/r/32084/diff/
Testing
-------
Modified testEmptyChannel as per new condition
Thanks,
Ashish Paliwal
