Reconnect due to socket error java.nio.channels.ClosedChannelException

storm整合kafka后出现如下异常:

 

错误原因:有部分kafka服务器连接不上导致,检查一下是不是每个kafka都能连接到(有的kafka配置使用的是host,记得配置相同的环境)

造成异常代码段:org.apache.storm.kafka.ZkCoordinator.refresh()



原文地址:https://www.cnblogs.com/gavinYang/p/11198114.html