Kafka-sarama：空闲超时后生产者是否应该自动重新连接？

问题描述

我有一个关于 sarama Go 语言 Kafka 库的看似简单的问题：当 Kafka 代理由于空闲超时（由 connections.max.idle.ms 配置控制）而关闭时，生产者是否应自动重新建立与代理何时/通过发送新消息？

我无法在我检查的任何资源中找到答案：

• Kafka documentation
• Kafka protocol guide
• sarama documentation

我之所以这么问是因为它似乎没有自动重新连接 - 现在我应该尝试避免超时（通过增加 connections.max.idle.ms 配置或发送心跳消息）还是应该向 sarama 提出问题？

我还查看了 sarama 日志，以了解此处实际发生的情况的线索（测试场景，每 10 分钟发送一次消息），但是，我对 Kafka 和 Go 都不熟悉，因此无法从中获得太多：

>

...
2021/02/03 07:55:46 producer/broker/0 starting up
2021/02/03 07:55:46 producer/broker/0 state change to [open] on <topic>/0
2021/02/03 07:55:46 Connected to broker at <hostIP>:30001 (registered as #0)
2021/02/03 08:05:46 client/metadata fetching metadata for all topics from broker <host>:30001
2021/02/03 08:06:46 producer/broker/0 state change to [closing] because EOF
2021/02/03 08:06:46 Closed connection to broker <hostIP>:30001
2021/02/03 08:06:46 producer/leader/<topic>/0 state change to [retrying-1]
2021/02/03 08:06:46 producer/leader/<topic>/0 abandoning broker 0
2021/02/03 08:06:46 producer/broker/0 input chan closed
2021/02/03 08:06:46 producer/broker/0 shut down
2021/02/03 08:07:01 Producer shutting down.
2021/02/03 08:15:46 client/metadata fetching metadata for all topics from broker <host>:30001
2021/02/03 08:25:46 client/metadata fetching metadata for all topics from broker <host>:30001
...

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）