如何修复使用kafka-python连接Red Panda时的KafkaTimeoutError

Question

尝试将

kafka-python

生产者连接到我的 Red Panda 数据库时，出现以下错误。


KafkaTimeoutError: KafkaTimeoutError: Failed to update metadata after 60.0 secs.

我有一个在 WSL 上运行的开发环境，以及 Docker 桌面上的 Red Pandas 容器。 Red Panda 分配了 1GB RAM，所以我不认为这是内存问题。

我使用以下方式连接到我的 Red Panda 经纪人：

producer = KafkaProducer(
    bootstrap_servers = '192.168.2.28:19092', 
    security_protocol = 'SSL',
    api_version=(0, 10, 1)
)

我必须添加

security_protocol

和

api_version

才能让制作者连接。我可以假设它已连接，因为运行该代码时我没有收到任何连接错误。

然后我尝试使用以下命令发送测试数据，但收到错误：

producer.send('test', b'Hello, World!')

我也尝试过不将文本分配为字节，但出现了相同的错误。

有谁知道如何修复此错误或有将生产者连接到 Red Panda 的经验，我也愿意使用

confluent-kafka

。

Answer 1

如果您没有在 Redpanda 中启用 SSL，则不需要 SSL。如果启用了 SSL，您还需要在生产者中配置证书或密钥库。但我认为 API 版本并不相关。希望有帮助。