当消费者准备使用消息并尝试使用ConsumerAwareRebalanceListener时,我试图捕捉该事件,但它不起作用。请建议一下。@Component
public class ConsumerAwareRebalanceListenerImpl implements ConsumerAwareRebalanceListener
我有一个实现DataConsumer.java的类ConsumerAwareRebalanceListenerpublic class DataConsumer implementsConsumerAwareRebalanceListener { public void onPartitionsAssigned(Consumer<?