所有监听器启动后的SpringKafka事件

Question

我正在使用 Spring-Kakfa 来连接 kakfa 集群，并且我需要在分配所有主题的所有主题分区后执行一段代码。以以下代码为例

     @Component
     public class MyKafkaMessageListener1 {
    
         @KafkaListener(topics = "topic1" , groupId = "cg1")
         public void handleMessage(String message){
               System.out.println("Msg:"+message);
         }
     }

     @Component
     public class MyKafkaMessageListener2 {
    
         @KafkaListener(topics = "topic2, topic3" , groupId = "cg2")
         public void handleMessage(String message){
               System.out.println("Msg:"+message);
         }
     }

我需要在将主题 1、主题 2 和主题 3 的所有主题分区分配给线程后执行。可能吗？kafka 或 spring-kafka 中有这样的 EventHandler 吗？

Answer 1

实现 ConsumerSeekAware（或扩展 AbstractConsumerSeekAware），或添加 ConsumerRebalanceListener，您将收到对 onPartitionsAssigned（） 的调用。