Details
-
Sub-task
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
Description
The new consumer group protocol will be sending one assignment to the member, and wait for an ack or timeout before sending any other assignment.
The client state machine will be updated so that it takes on new target assignment only if there is no other in process. If a new target assignment is received in this case, the member should fail with a fatal error, as this is not expected in the protocol.
Attachments
Issue Links
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved
- links to