You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by hun shenshi <28...@qq.com> on 2017/06/08 13:44:30 UTC

Review Request 59916: FLUME-3104. Add PutRollbackTimes and TakeRollbackTimes in Kafka Channel metrics

-----------------------------------------------------------
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