[Solved] Which of the following is the correct way to listen for rebalance events in Kafka consumer code? — Ans: consumer.subscribe(topics, new ConsumerRebalanceListener() {...}) | Kafka

Kafka - Consumer Groups

Which of the following is the correct way to listen for rebalance events in Kafka consumer code?

Aconsumer.subscribe(topics, new ConsumerRebalanceListener() {...})

Bconsumer.on('rebalance', callback)

Cconsumer.addRebalanceListener(callback)

Dconsumer.listenRebalance(callback)

Step-by-Step Solution

Solution:

Step 1: Recall Kafka consumer API
Kafka's Java consumer uses subscribe with a ConsumerRebalanceListener to handle rebalance events.
Step 2: Match correct syntax
Only consumer.subscribe(topics, new ConsumerRebalanceListener() {...}) shows the correct method signature for rebalance listener.
Final Answer:
consumer.subscribe(topics, new ConsumerRebalanceListener() {...}) -> Option A
Quick Check:
Use subscribe with ConsumerRebalanceListener [OK]

Quick Trick: Use subscribe with ConsumerRebalanceListener for rebalance [OK]

Common Mistakes:

Master "Consumer Groups" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Which of the following is the correct way to listen for rebalance events in Kafka consumer code?