storm整合kafka后出現如下異常：
錯誤原因：有部分kafka服務器連接不上導致，檢查一下是不是每個kafka都能連接到（有的kafka配置使用的是host，記得配置相同的環境）
造成異常代碼段：org.apache.storm.kafka.ZkCoordinator.refresh()
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。
猜您在找
java.nio.channels.ClosedChannelException
hadoop java.nio.channels.ClosedChannelException
Netty 中 IOException: Connection reset by peer 與 java.nio.channels.ClosedChannelException: null
Java訪問kafka的時候java.nio.channels.ClosedChannelException解決辦法
JAVA NIO Socket通道
java nio socket實例
java 連接Kafka報錯java.nio.channels.ClosedChannelExcep
Java NIO4：Socket通道
Java Socket IO（BIO、NIO）
Java Socket NIO示例總結