Spring Kafka Event after all listeners are started

207
August 07, 2021, at 2:00 PM

I'm using Spring-Kakfa to connect kakfa cluster and I have a requirement to execute a piece of code after all the topic partitions of all the topics are assigned. take the following code for example

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

I need to execute after all topic-partitions of topic1, topic2 and topic3 are assigned to threads. Is it possible? Is there such a EventHandler in kafka or spring-kafka?

Rent Charter Buses Company
READ ALSO
missing ic_affirmation_foreground.xml for android developer tutorial

missing ic_affirmation_foreground.xml for android developer tutorial

I'm trying to complete a codelab where I polish the UI on an affirmations app and it tells me to download the files ic_affirmation_foregroundxml and ic_affirmation_background

199
Required field form by using id attribute in Javascript

Required field form by using id attribute in Javascript

here is my formWhen user want to add another form they just click the "tambah bil"

131
Looking for differences in two CSV files with Python

Looking for differences in two CSV files with Python

I have a script that scrapes a site and puts specific site names into a csvSome days it has 0 site names and some days it has more the 4

199
Check for the status of insufficient balance from Stripe during create subscription

Check for the status of insufficient balance from Stripe during create subscription

Currently I am facing an issue of not able to retrieve the status of insufficient balance during subscription creationI am using the below link to retrieve status as a reference, but not able to do this

247