c++ - 如何解决 librdkafka 中的 RdKafka::ERR__TIMED_OUT 和 RdKafka::ERR__MSG_TIMED_OUT？

Question

我正在开发 C++ kafka 客户端 librdkafka。查看示例 https://github.com/edenhill/librdkafka/blob/master/src-cpp/rdkafkacpp.h和 https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp ，好像没有连接broker的过程？如何为这些连接错误做一些重新连接工作人员？如何查看连接状态？

Answer 1

librdkafka 从应用程序中抽象出所有代理连接，它将尝试始终保持与每个已知代理的连接(通过 metadata.broker.list 学习或从第一个 Bootstrap 返回的代理列表经纪人)。

一旦出现连接错误，librdkafka 将永远尝试再次连接。

如果没有代理可以连接到 ALL_BROKERS_DOWN 事件将被触发，但当前没有代理何时恢复在线的相应事件。应用程序无需担心，因为 librdkafka 会在后台处理所有重新连接和消息重新传输，并且它将继续尝试生成消息，直到 message.timeout.ms 或 超过 message.send.max.retries。

介绍指南中有更多相关信息: https://github.com/edenhill/librdkafka/blob/master/INTRODUCTION.md