[KAFKA-6968] Call RebalanceListener in MockConsumer

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: consumer
• Assignee: Unassigned
• Reporter: Andras Beni
• Created: 30/May/18 08:08
• Updated: 04/Dec/23 23:06

Description

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.

Issue Links

• links to: GitHub Pull Request #7539