Как сообщить потребителю spring-kafka о прекращении потребления во время выполнения?

Question

Я использую spring-kafka v2.5.2 с аннотациями KafkaListener.

Во время выполнения я хотел бы отправить сигнал потребителю, чтобы он прекратил потребление.

I см. параметр autoStartup, но, похоже, он работает только для инициализации и не может быть изменен после.

Я вижу метод close () в KafkaListenerEndpointRegistry ...

Есть ли у вас предложения ?

Заранее спасибо.

Answer 1

Дайте каждому слушателю атрибут id; затем вы можете использовать bean-компонент KafkaListenerEndpointRegistry, чтобы получить ссылку на контейнер слушателя, который затем можно запускать и останавливать: getListenerContainer("myId").stop().

Это задокументировано здесь .