Hi there,

I have created a Java Extension to consume Kafka message. The pseudocode is like this:

while(is_true){

message = consumer.poll();

process(message);

}

In Java Extension it is put in static method of a class.

My questions are:

1. Where should i put it - as i ask here before that this looping cannot run forever as the server action will be kicked by the application server?

2. If i use another thread to stop that pooling, how to do it?

thanks and regards,