如何停止在 Spring Kafka 消费者中收听？答案

【问题标题】：How to stop listening in a Spring Kafka consumer?如何停止在 Spring Kafka 消费者中收听？
【发布时间】：2020-05-02 05:47:15
【问题描述】：

我使用Spring for Apache Kafka。我想停止听我的话题，等待逃离 OOM。我该怎么做？

【问题讨论】：

您可以使用消费者的 pause() 和 resume() 方法。
有趣的是 StackOverflow 如何防止修复这个问题中的几个拼写错误，因为最小的编辑必须是 10 个字符。

标签： java spring spring-boot apache-kafka spring-kafka

【解决方案1】：

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

【讨论】：

什么是consumersMap？

【解决方案2】：

您可以简单地使用这些指南来停止监听 Kafka 消费者。

1- kafka-util

2- Start/Stop Kafka Consumers using Spring Kafka

【讨论】：

【解决方案3】：

Kafka 提供了一个选项来暂停（）和恢复（）主题的消费。您可以通过在两者之间实现等待以从内存问题中恢复来使用这些方法。

参考：https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html

【讨论】：

问题是关于 Spring Kafka，而不是普通的 Kafka。