我们在linux机器上有一个简单的独立模式部署kafka 1.1.0。在已修改的server.properties中:
listeners = PLAINTEXT://10.0.5.66:9092
``` `advertised.listeners` 被注解掉,因此它将返回到中的默认值 `listeners` 财产。
我们使用的是.net(c#)生产者,它通过融合的kafka dotnet(0.11.4)推送消息。有时消息被传输到kafka,有时我们在生产者端收到“消息超时”错误。我们已经不知道是什么导致了这个问题。这种情况时有发生。如果一条消息失败,另一条消息通常在第一条消息几秒钟后通过。
另一个痕迹可能是,我们不时在服务器上的Kafka日志中看到以下消息: `WARN: Attempting to send response via channel for which there is no open connection <IP:PORT>` . 此消息有时包含生产者的ip地址和端口。
你知道怎么回事吗?
暂无答案!
目前还没有任何答案,快来回答吧!