unknowntpo opened a new pull request, #23420: URL: https://github.com/apache/kafka/pull/23420
The exactly-once source system test can report that all source tasks produced no records because its validation consumer times out before receiving the first fetch response. The console consumer timeout also covers group initialization and the first fetch. Increase the timeout from one second to ten seconds for both the read-committed validation consumer and the diagnostic consumer. Keep the existing missing-sequence and duplicate-sequence checks unchanged. Validation performed on Kafka commit `9ec73ca7b08b0c7205a19831acfbad146520823f`, the revision tested by [Jenkins kafka-e2e #928](https://jenkins.opensource4you.tw/job/kafka-e2e/928/): - Full `ConnectDistributedTest.test_exactly_once_source` with `clean=False`, `connect_protocol=eager`, and `metadata_quorum=ISOLATED_KRAFT`: unmodified test FAIL, modified test PASS with JDK 17. The three tasks reached sequence numbers 9559, 9638, and 9042 without missing or duplicate sequences. - A separate real-broker startup reproduction with a fresh classic consumer group and a three-second initial rebalance delay returned zero records with the one-second timeout and all 300 records with the ten-second timeout, in all three paired runs. - Python syntax and `git diff --check` pass. The patch was rebased onto current trunk; the target file was unchanged between the tested base and trunk. E2E was not rerun on the rebased head, and the other parameter combinations were not rerun. Generated-by: OpenAI Codex (GPT-6) -- 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]
