confluentkafkapython在producer中未捕获飞行中超时的元数据请求

2024-06-13 14:09:08 发布

您现在位置:Python中文网/ 问答频道 /正文

嗨,我们的kafka已经崩溃了大约2天,而我们的一个使用confluent kafka for python的制作者仍然尝试生成一条消息,而我们收到的日志显示Timed out MetadataRequest in flightMetadata request failed: periodic topic and broker list refresh: Local: Host Resolution failure

现在我们的问题是,生产者没有像任何其他回调和异常一样捕获这些错误,它像那样被卡住,直到我们重新启动生产者

你能帮我们找到为什么它没有像其他日志一样捕获这些日志吗?我们在交付和错误时使用回调,并且每个函数都包含异常

也是什么导致了这个错误,直到现在我们才发现这个错误

也可能你知道我们如何重现这个错误,这样我们就可以试着在我们的计算机上调试它

谢谢


Tags: kafkain消息forrequest错误outflight