时间戳

首页 > 解决方案 > Kafka - C# - confluent-kafka-dotnet - 消息超时

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

问题描述

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

listeners = PLAINTEXT://10.0.5.66:9092

advertised.listeners被注释掉，所以它应该回退到listeners属性中找到的默认值。

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

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

知道可能出了什么问题吗？

标签： c#apache-kafkatimeoutconfluent-platform

解决方案

推荐阅读