Description
This implements the group management protocol. This will be a tricky and potentially large change since it will involve implementing the group management protocol, which include:
1) Adding the rebalance logic on the coordinator that can be triggered from membership change (either through failure detector or join group requests) and topic / partition ZK listener fires.
2) Adding the rebalance logic on the consumer upon topic change / error code from coordinator.
Attachments
Issue Links
- is blocked by
-
KAFKA-1334 Coordinator should detect consumer failures
-
- Resolved
-