[ https://issues.apache.org/jira/browse/KAFKA-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eduardo Pinto reassigned KAFKA-6968: ------------------------------------ Assignee: (was: Eduardo Pinto) > Call RebalanceListener in MockConsumer > -------------------------------------- > > Key: KAFKA-6968 > URL: https://issues.apache.org/jira/browse/KAFKA-6968 > Project: Kafka > Issue Type: Improvement > Components: consumer > Affects Versions: 1.1.0 > Reporter: Andras Beni > Priority: Minor > > {{org.apache.kafka.clients.consumer.MockConsumer}} simulates rebalance with > method {{public synchronized void rebalance(Collection<TopicPartition> > newAssignment)}}. This method does not call {{ConsumerRebalanceListener}} > methods. Calls to {{onPartitionsRevoked(...)}} and > {{onPartitionsAssigned(...)}} should be added in appropriate order. -- This message was sent by Atlassian Jira (v8.20.10#820010)