Как перестать перечислять потребителя кафки?

Question

Я использую Spring for Apache Kafka. Я хотел бы прекратить перечислять мои топи c и подождать, пока не выйдет из ООМ Как я могу это сделать?

Answer 1

Kafka предоставляет возможность приостановить () и возобновить () потребление из topi c. Вы можете использовать эти методы, реализовав промежуточное ожидание для восстановления проблемы с памятью.

Ссылка: https://kafka.apache.org/0100/javadoc/index.html?org / apache / kafka / clients / consumer / KafkaConsumer. html

Answer 2

Вы можете просто использовать эти Руководства, чтобы прекратить слушать потребителей Kafka.

1- kafka-util

2- Запуск / остановка потребителей Kafka с использованием Spring Kafka

Answer 3

 public static void stopConsumer(final String topic) {    
     ConcurrentMessageListenerContainer<String, String> container 
         = consumersMap.get(topic);
     container.stop();    
 }