Skip to content

Calculate batchElapsedTime correctly by converting startTime from nan…#417

Open
SamBhandary wants to merge 1 commit intoapache:flume-1.11from
SamBhandary:SamBhandary-KafkaChannelCallback
Open

Calculate batchElapsedTime correctly by converting startTime from nan…#417
SamBhandary wants to merge 1 commit intoapache:flume-1.11from
SamBhandary:SamBhandary-KafkaChannelCallback

Conversation

@SamBhandary
Copy link

ISSUE: batchElapsedTime calculated incorrectly.

[DEBUG - org.apache.flume.channel.kafka.ChannelCallback.onCompletion(KafkaChannel.java:760)] Acked message_no 793: test-3-280448-1667034684768

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant