[ https://issues.apache.org/jira/browse/KAFKA-15276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kirk True updated KAFKA-15276: ------------------------------ Summary: Implement event plumbing for ConsumerRebalanceListener callbacks (was: Implement partition assignment reconciliation callbacks) > Implement event plumbing for ConsumerRebalanceListener callbacks > ---------------------------------------------------------------- > > Key: KAFKA-15276 > URL: https://issues.apache.org/jira/browse/KAFKA-15276 > Project: Kafka > Issue Type: Sub-task > Components: clients, consumer > Reporter: Kirk True > Assignee: Kirk True > Priority: Blocker > Labels: kip-848, kip-848-client-support, kip-848-e2e, > kip-848-preview > > Provide the Java client support for the consumer group partition assignment > logic, including: > * Calculate the difference between the current partition assignment and that > returned in the {{ConsumerGroupHeartbeatResponse}} RPC response > * Ensure we handle the case where changes to the assignment take multiple > passes of {{RequestManager.poll()}} > * Integrate the mechanism to invoke the user’s rebalance callback > This task is part of the work to implement support for the new KIP-848 > consumer group protocol. -- This message was sent by Atlassian Jira (v8.20.10#820010)