Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
When users are using group management, if they call consumer.subscribe() to change the subscription, the removed subscriptions will be immediately removed and their offset will not be commit. Also the revoked partitions passed to the ConsumerRebalanceListener.onPartitionsRevoked() will not include those partitions.
Attachments
Issue Links
- Is contained by
-
KAFKA-4033 KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change
- Resolved
- links to