"经纪人运输失败"在卡夫卡意味着什么？

Question

我正在使用python客户端(Confulent kafka)从kafka使用.有时消费者会遇到如下错误:

ERROR KafkaError{code=_TRANSPORT,val=-195,str="GroupCoordinator response error: Local: Broker transport failure"}

有人可以帮忙解释错误是什么意思吗？"运输失败"似乎意味着消费者与经纪人有网络问题,是吗？发生此错误时该怎么办？

Answer 1

问题摘要询问“代理传输失败”，这可能是许多不同的事情。但重点关注问题详细信息，它给出了完整的错误消息“GroupCoordinator 响应错误：本地：代理传输失败”，这很可能是由以下原因引起的：

如果是这样，那么它并不是真正的错误，可以安全地忽略。Kafka 客户端会处理它，尽管每个人在日志中收到此错误消息然后需要去调查它都很烦人

上述github问题给出的建议解释是：

可能存在这样的情况：空闲连接收割机可能会在消费者进程向其发出 GroupCoordinator 请求的同时“杀死”代理连接。在这种情况下，poll 方法会将错误消息返回给应用程序（假设类似于 PARTITION_EOF 消息）。

即使这种解释不是 100% 正确，一位维护者在同一个线程中说：

作为基于 librdkafka 的客户端的一般规则：假设集群和客户端配置正确，所有错误都可以忽略，因为它们很可能是暂时的，并且 librdkafka 将尝试自动恢复。