RohithDevarshetty opened a new pull request, #23239:
URL: https://github.com/apache/kafka/pull/23239
## Summary
Record queue time for producer batches that expire in the accumulator
before being sent. This ensures record-queue-time-max reflects time spent
waiting by timed-out batches, not only batches included in produce requests.
## Testing
- Added SenderTest.testRecordQueueTimeIncludesBatchesExpiredInAccumulator
to verify the metric is updated when an unsent batch expires.
_Used Codex_
--
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]
