Spring Kafka Event, nachdem alle Listener gestartet wurden ⇐ Java

[Anonymous]

Ich verwende Spring-Kafka, um den Kafka-Cluster zu verbinden, und muss einen Code ausführen, nachdem alle Themenpartitionen aller Themen zugewiesen wurden.
Nehmen Sie den folgenden Code als Beispiel:

Code: Select all

     @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);
}
}

Ich muss ausführen, nachdem alle Themenpartitionen von Thema 1, Thema 2 und Thema3 Threads zugewiesen wurden. Ist es möglich? Gibt es einen solchen EventHandler in Kafka oder Spring-Kafka?