----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/59916/ -----------------------------------------------------------
Review request for Flume. Bugs: FLUME-3104 https://issues.apache.org/jira/browse/FLUME-3104 Repository: flume-git Description ------- Add PutRollbackTimes and TakeRollbackTimes in Kafka Channel metrics Diffs ----- flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java 5bd9be0 flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java 5e5f2d0 flume-ng-core/src/main/java/org/apache/flume/instrumentation/kafka/KafkaChannelCounter.java 28d3c8c flume-ng-core/src/main/java/org/apache/flume/instrumentation/kafka/KafkaChannelCounterMBean.java da64f0c Diff: https://reviews.apache.org/r/59916/diff/1/ Testing ------- mvn clean install -DskipTests -> built junit tests for flume-taildir-source module -> passed Thanks, hun shenshi