You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "praiyani6789 (via GitHub)" <gi...@apache.org> on 2026/03/03 08:38:58 UTC
[PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
praiyani6789 opened a new pull request, #21618:
URL: https://github.com/apache/kafka/pull/21618
The `record-e2e-latency-max` metric at terminal nodes uses `currentSystemTimeMs()` (cached time frozen at the start of record processing) instead of live wall clock time. This causes the metric to ignore processing delays introduced by intermediate nodes.
**Fix:** Use `time.milliseconds()` when recording e2e latency at terminal nodes to capture true end-to-end latency including all processing delays.
**Testing:** Added test demonstrating a 3-second processing delay is correctly reflected in the metric (~3010ms) instead of being ignored (~10ms).
Fixes: https://issues.apache.org/jira/browse/KAFKA-14597
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
Posted by "praiyani6789 (via GitHub)" <gi...@apache.org>.
praiyani6789 closed pull request #21618: KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes
URL: https://github.com/apache/kafka/pull/21618
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #21618:
URL: https://github.com/apache/kafka/pull/21618#issuecomment-4999003314
This PR is being marked as stale since it has not had any activity in 90 days. If you
would like to keep this PR alive, please leave a comment asking for a review. If the PR has
merge conflicts, update it with the latest from the base branch.
<p>
If you are having difficulty finding a reviewer, please reach out on the
[mailing list](https://kafka.apache.org/contact).
<p>
If this PR is no longer valid or desired, please feel free to close it. If no activity
occurs in the next 30 days, it will be automatically closed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
Posted by "mjsax (via GitHub)" <gi...@apache.org>.
mjsax commented on PR #21618:
URL: https://github.com/apache/kafka/pull/21618#issuecomment-4269231089
@praiyani6789 -- Any updates from your side on this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
Posted by "praiyani6789 (via GitHub)" <gi...@apache.org>.
praiyani6789 commented on PR #21618:
URL: https://github.com/apache/kafka/pull/21618#issuecomment-4999037573
This has been covered in #22452
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org