“KafkaListenerEndpointRegistry.stop()” functionality and making it work on distributed environment I have a Kafka consumer configured with setup like:
