使用Streamparser搭建Storm拓扑时遇连接拒绝错误求助

• 检查Nimbus进程状态
  先确认Nimbus是否正常启动：

  jps | grep Nimbus
  # 或者用ps命令排查
  ps aux | grep nimbus
  

  如果未找到Nimbus进程，查看Nimbus日志定位启动失败原因：

  cat storm/logs/nimbus.log
  

  常见失败原因包括依赖的ZooKeeper未启动、storm.local.dir目录不存在或权限不足。

• 验证ZooKeeper服务可用性
  Storm依赖ZooKeeper协调集群，先确认ZK服务正常运行：

  # 检查ZK运行状态（默认ZK安装的命令）
  zkServer.sh status
  # 测试端口连通性
  nc -zv localhost 2181
  

  如果ZK未启动，先启动ZK服务：

  zkServer.sh start
  

• 修复storm.local.dir配置与权限
  配置文件中storm.local.dir指定的路径必须真实存在，且Storm运行用户拥有读写权限：

  1. 创建目标目录（如果不存在）：

     mkdir -p /your/actual/storm-local-path
     

  2. 设置正确的权限（假设运行Storm的用户为storm）：

     chown -R storm:storm /your/actual/storm-local-path
     chmod -R 755 /your/actual/storm-local-path
     

  3. 修改storm.yaml中的storm.local.dir为实际路径，保存后重启Nimbus。

• 检查Nimbus端口监听状态
  确认Nimbus的Thrift端口（6627）是否被正确监听：

  ss -tulpn | grep 6627
  

  如果输出中无Java进程监听该端口，说明Nimbus启动失败，回到日志排查；如果端口已监听，测试本地连通性：

  nc -zv localhost 6627
  

• 确保配置文件语法与一致性
  YAML配置对缩进敏感，检查storm.yaml的缩进是否全用空格（禁止使用Tab），同时确认nimbus.seeds和nimbus.thrift.port在所有节点配置中一致（单节点环境下只需保证本地配置正确）。

• 按正确顺序重启Storm服务
  集群启动必须遵循以下顺序：

  1. 启动ZooKeeper
  2. 启动Nimbus，等待日志输出Nimbus ready后再进行下一步
  3. 启动Supervisor
  4. 启动UI

内容的提问来源于stack exchange，提问作者Tinniam V. Ganesh