Spring kafka消费者停止接收消息答案

【问题标题】：Spring kafka consumer stops receiving messageSpring kafka消费者停止接收消息
【发布时间】：2019-03-01 13:24:17
【问题描述】：

我有一个使用 kafka 的 Spring 微服务。

这是消费者 5 配置属性：

BOOTSTRAP_SERVERS_CONFIG -> <ip>:9092
KEY_DESERIALIZER_CLASS_CONFIG -> StringDeserializer.class
VALUE_DESERIALIZER_CLASS_CONFIG -> StringDeserializer.class
GROUP_ID_CONFIG -> "Group1"
MAX_POLL_INTERVAL_MS_CONFIG -> Integer.INT_MAX

已经观察到，当微服务重启时，kafka 消费者停止接收消息。请帮帮我。

【问题讨论】：

你认为第三者有可能告诉你问题出在哪 5 个属性上吗？
需要更多详细信息，此信息不足

标签： spring spring-boot apache-kafka kafka-consumer-api

【解决方案1】：

我相信你的 max.poll.interval.ms 是问题所在。设置为24天！！这表示消费者被给予处理消息的时间。当处理线程死亡时，代理将挂起那么长时间！尝试将其设置为小于 Integer.INT_MAX 的值，例如 30 秒 30000 毫秒。

【讨论】：