微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决Kafka-sarama:空闲超时后生产者是否应该自动重新连接?

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

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

我之所以这么问是因为它似乎没有自动重新连接 - 现在我应该尝试避免超时(通过增加 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 举报,一经查实,本站将立刻删除。