bbejeck opened a new pull request, #23191:
URL: https://github.com/apache/kafka/pull/23191
Follow-up to #23144, which routed `putAll` through the transactional buffer
by reusing `cfAccessor.put` (called once per entry). Each put invokes
`updatePosition`, so this adds a test proving that every entry in one `putAll`
shares the same record context, making the per-entry updates idempotent — the
position lands exactly where a single update at that offset would, regardless
of batch size.
Test-only; no production
changes.
--
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]
