我正在使用一个python客户机（confulent kafka）来使用kafka。有时消费者会遇到如下错误：
ERROR KafkaError{code=_TRANSPORT,val=-195,str="GroupCoordinator response error: Local: Broker transport failure"}有人能解释一下这个错误是什么意思吗？”“传输失败”似乎意味着消费者与经纪人之间存在网络问题，对吗？发生此错误时我应该怎么做？
我正在使用一个python客户机（confulent kafka）来使用kafka。有时消费者会遇到如下错误：
ERROR KafkaError{code=_TRANSPORT,val=-195,str="GroupCoordinator response error: Local: Broker transport failure"}有人能解释一下这个错误是什么意思吗？”“传输失败”似乎意味着消费者与经纪人之间存在网络问题，对吗？发生此错误时我应该怎么做？
1条答案
按热度按时间i1icjdpr1#
问题摘要询问“代理传输失败”，这可能是许多不同的事情。但是关注问题细节，它给出了完整的错误消息“groupcoordinator response error:local:broker transport failure”，这很可能是由以下原因造成的：
https://github.com/edenhill/librdkafka/issues/1987
如果是这样，那么它就不是一个真正的错误，可以安全地忽略。Kafka客户机将处理它，虽然这是恼人的每个人都得到这个错误消息在他们的日志，然后需要去调查它
关于上述github问题的建议解释如下：
可能存在这样的情况：空闲连接收割器可能会在使用者进程向代理连接发出groupcoordinator请求的同时“杀死”代理连接。在这种情况下，poll方法将向应用程序返回错误消息（假设类似于partition\eof消息）。
即使这个解释不是100%正确，其中一个维护人员在同一个线程中说：
基于librdkafka的客户机的一般规则是：如果集群和客户机配置正确，则可以忽略所有错误，因为它们很可能是临时的，librdkafka将尝试自动恢复。