@KafkaListener在kafka集群关闭后陷入无限循环

Question

我有一个由3个节点组成的kafka集群，我使用debezium(一个kafka-mysql连接器)。

我用@KafkaListener作为主题使用者编写了一个方法。

然后我手动关闭kafka集群(杀死-15)。

然后，听众突然陷入了一个无限的循环。

顶级命令

​

​

jstack

​

​

和使用者日志(无限)

​

​

这是个虫子吗？获得异常是可以接受的，但我不希望CPU使用率达到100%。

Answer 1

这是底层kafka客户端的行为，直到0.11.0.0。

reconnect.backoff.ms属性是在0.11.0.0客户机(CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG)中添加的-参见卡夫卡-5766和kafka文献。

SpringKafka1.3.x使用0.11客户机(和2.0.x)。SpringKafka2.1.x使用当前的1.0.0客户机。