Skip to content

KAFKA-14672: Record queue time for expired accumulator batches - #23239

Open
RohithDevarshetty wants to merge 1 commit into
apache:trunkfrom
RohithDevarshetty:KAFKA-14672-record-queue-time-expired-batches
Open

KAFKA-14672: Record queue time for expired accumulator batches#23239
RohithDevarshetty wants to merge 1 commit into
apache:trunkfrom
RohithDevarshetty:KAFKA-14672-record-queue-time-expired-batches

Conversation

@RohithDevarshetty

@RohithDevarshetty RohithDevarshetty commented Aug 22, 2026

Copy link
Copy Markdown

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.

@github-actions github-actions Bot added triage PRs from the community producer clients small Small PRs labels Aug 22, 2026
@RohithDevarshetty RohithDevarshetty changed the title KAFKA-14672 Accumulator queue time recording KAFKA-14672: Record queue time for expired accumulator batches Aug 22, 2026
@RohithDevarshetty
RohithDevarshetty force-pushed the KAFKA-14672-record-queue-time-expired-batches branch from d9d6f11 to e8b2680 Compare August 22, 2026 13:31
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

clients producer small Small PRs triage PRs from the community

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant