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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
