Kafka - C# - confluent-kafka-dotnet - 消息超时

Tec*_*rap 5 c# timeout apache-kafka confluent-platform

我们在 Linux 机器上有一个简单的 Kafka 1.1.0 独立模式部署。在 server.properties 中,我们修改了:

listeners = PLAINTEXT://10.0.5.66:9092
Run Code Online (Sandbox Code Playgroud)

advertised.listeners被注释掉,因此它将回退到listeners属性中找到的默认值。

我们正在使用 .NET (C#) 生产者,它通过 confluent-kafka-dotnet (0.11.4) 推送消息。有时消息会传输到 Kafka,有时我们会在生产者端收到“消息超时”错误。对于可能导致此问题的原因,我们没有任何想法。它不时发生。如果一条消息失败,另一条消息通常会在第一条消息通过后几秒钟出现。

另一个迹可从我们不时在服务器上的日志,卡夫卡看到以下消息:WARN: Attempting to send a response via a channel for which there is no open connection <IP:PORT>。此消息有时包含生产者的 IP 地址和端口。

知道可能有什么问题吗?