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

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

 

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

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

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

 

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-08-20
猜你喜欢
  • 2021-08-15
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-08-14
  • 2021-04-28
  • 2022-12-23
相关资源
相似解决方案