python - confluent-kafka-python 在生产者的飞行中没有捕捉到超时的元数据请求

问题描述

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

现在我们的问题是生产者没有像任何其他回调和异常一样捕获这些错误，并且在我们重新启动生产者之前它就这样卡住了。

您能帮我们找出为什么它没有像我们在交付时使用回调和 error_cb 的任何其他日志一样捕获这些日志，并且每个函数都包含异常。

还有是什么导致了这个错误，直到现在我们还没有收到这个错误。

另外，也许您知道我们如何重现此错误，以便我们可以尝试在我们的 on 上调试它，

谢谢！

标签： pythonapache-kafkaconfluent-platformkafka-pythonconfluent-kafka-python

python - confluent-kafka-python 在生产者的飞行中没有捕捉到超时的元数据请求

问题描述

解决方案

推荐阅读