Kafka java.nio.channels.ClosedChannelException

最近开始部署一个工程时遇到了Kafka消费的问题,报错信息如下:

相关的工程已经在测试环境测试过了,部署到新的环境上却报错了。所以这个问题应该是环境问题或配置问题。

进入Kafka源码可以发现这个问题是在连接Kafka Broker时出现的。所以这个问题应该是网络连接导致的。找运维部的同事看了一下,确认是相关的节点与Kafka集群的通信被屏蔽了。解除屏蔽后问题就得到修复了。

在StackOverflow上也查过相关的问题,多是类似的缘故,比如host的错误配置等。

发表评论

This site uses Akismet to reduce spam. Learn how your comment data is processed.