嗨,我们的kafka已经崩溃了大约2天了,而我们的一个使用confluent kafka for python的制作者仍然试图生成一条消息,而我们收到的日志显示 Timed out MetadataRequest in flight
以及 Metadata request failed: periodic topic and broker list refresh: Local: Host Resolution failure
现在我们的问题是,生产者没有像任何其他回调和异常一样捕捉到这些错误,它就这样被卡住了,直到我们重新启动生产者。
你能帮我们找到为什么它没有像其他日志一样捕获这些日志吗?我们使用的是交付时回调和错误\u cb,并且每个函数都包含异常。
也是什么导致了这个错误,直到现在我们才得到这个错误。
也可能你知道我们如何重现这个错误,这样我们就可以试着在我们的电脑上调试它,
谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!