Repository: flume Updated Branches: refs/heads/trunk e43000609 -> d8638afd3
FLUME-2988 Kafka Sink metrics missing eventDrainAttemptCount Adding missing counter to KafkaSink Reviewers: Denes Arvay, Attila Simon, Ferenc Szabo (Udai Kiran Potluri via Ferenc Szabo) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/d8638afd Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/d8638afd Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/d8638afd Branch: refs/heads/trunk Commit: d8638afd314368128f244b6f53559f09a0d83097 Parents: e430006 Author: Ferenc Szabo <[email protected]> Authored: Thu Nov 22 10:51:56 2018 +0100 Committer: Ferenc Szabo <[email protected]> Committed: Thu Nov 22 10:51:56 2018 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/kafka/KafkaSink.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/d8638afd/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java index 3d56caa..d32753f 100644 --- a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java +++ b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java @@ -172,6 +172,7 @@ public class KafkaSink extends AbstractSink implements Configurable, BatchSizeSu } break; } + counter.incrementEventDrainAttemptCount(); byte[] eventBody = event.getBody(); Map<String, String> headers = event.getHeaders();
