Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
Description
eventDrainAttemptCount doesn't get incremented in Kafka Sink, only the eventDrainSuccessCount (https://github.com/apache/flume/blob/trunk/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java#L210) resulting in misleading statistics (e.g. when calculating attemptCount - successCount)