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.