Hi Team,

While working on a project, I have a requirement to control Kafka listeners
via a specific topic. During this, the pause() and resume() methods are
working as expected.

However, if I call stop() and then start() on a listener at runtime, any
messages published in between are not consumed after the listener is
started again. I am using *Spring Boot 3.5.0* and managing containers via
the KafkaListenerEndpointRegistry class.

Interestingly, if I restart the application and then publish messages, the
listeners consume them without any issue.

Could you please help me understand why the stop() and start() methods are
not working as expected at runtime?

Thank you,
Nageswararao Edara.

Reply via email to