Spring Kafka Event после запуска всех слушателей ⇐ JAVA

[Anonymous]

Я использую Spring-kafka для подключения кластера Kafka, и мне нужно выполнить фрагмент кода после назначения всех разделов всех тем.
Возьмем, к примеру, следующий код:

Код: Выделить всё

     @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 будут назначены потокам. Является ли это возможным? Есть ли такой EventHandler в Kafka или Spring-Kafka?

Подробнее здесь: https://stackoverflow.com/questions/686 ... re-started