MdTanwer opened a new pull request, #23213: URL: https://github.com/apache/kafka/pull/23213
This change is my original work and I license it to the Apache Kafka project under the Apache License 2.0. ## Summary - Classic `ConsumerCoordinator` no longer retries `UNKNOWN_TOPIC_OR_PARTITION` while auto-committing before JoinGroup (`onJoinPrepare`). A deleted topic cannot recover; the old retry loop blocked rebalance and, with the EAGER protocol, paused fetches for all assigned partitions (regex subscribe + topic delete). - Auto-commit now omits partitions whose topics have left the subscription (regex drop). `COORDINATOR_LOAD_IN_PROGRESS` is still retried. User `commitSync` still retries UTOR. Fixes KAFKA-16235 (regression since 3.2.1 after KAFKA-14024). Aligns classic rebalance commit with KAFKA-16224 on the new consumer. ## Test plan - [x] `EagerConsumerCoordinatorTest` / `CooperativeConsumerCoordinatorTest` (full classes) - [x] UTOR during `onJoinPrepare` continues join - [x] Regex-deleted topic does not stall rebalance auto-commit - [x] User `commitOffsetsSync` still retries UTOR - [x] `:clients:checkstyleMain` `:clients:checkstyleTest` `:clients:spotlessCheck` Made with [Cursor](https://cursor.com) -- 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]
