tgolob opened a new pull request, #23957: URL: https://github.com/apache/kafka/pull/23957
`TopologyTestDriver` shares an offset counter between concrete topics matching the same source pattern. After records A, A, B, it assigns offsets 0, 1, 2 instead of 0, 1, 0. This can make a position-bound store query succeed before the required record from B has been processed. Track regular input offsets per concrete topic, with separate counters for global inputs. The change is limited to test-driver offset generation: pattern inputs retain their existing task queues, assignment, and idling behavior. Mock commit offsets derived from input records change with the corrected metadata; the synthetic queue/commit model is retained. Add regression coverage for per-topic record metadata and position-bound queries in `at_least_once` and `exactly_once_v2` modes. -- 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]
