IntelliJ本地运行Storm ExclamationTopology遇NimbusLeaderNotFoundException

我来帮你搞定这个Storm本地运行的问题——你遇到的NimbusLeaderNotFoundException其实是个很常见的坑，主要是因为代码或配置没适配本地内存模式的运行逻辑，下面一步步给你排查解决：

问题核心原因 #

你用的是Storm内存版本（也就是LocalCluster本地集群模式），但你的代码可能默认尝试连接远程Nimbus集群，或者Maven插件的启动配置没到位，导致程序找不到本地需要的Nimbus服务（毕竟内存模式不需要单独启动Nimbus，它是内嵌在进程里的）。

具体解决方案 #

1. 修正拓扑代码，改用LocalCluster模式 #

首先检查你的ExclamationTopology主类，必须明确使用本地集群提交拓扑，不能用远程集群的提交方法。正确的代码示例如下：

import org.apache.storm.LocalCluster;
import org.apache.storm.Config;
import org.apache.storm.topology.TopologyBuilder;

public class ExclamationTopology {
    public static void main(String[] args) throws Exception {
        TopologyBuilder builder = new TopologyBuilder();
        
        // 这里是你的拓扑组件定义（示例）
        builder.setSpout("word-spout", new WordSpout());
        builder.setBolt("exclamation-bolt", new ExclamationBolt())
               .shuffleGrouping("word-spout");
        
        // 关键：用LocalCluster而不是StormSubmitter
        Config config = new Config();
        LocalCluster localCluster = new LocalCluster();
        localCluster.submitTopology("exclamation-topology", config, builder.createTopology());
        
        // 可选：设置运行时长后自动关闭集群
        Thread.sleep(15000);
        localCluster.killTopology("exclamation-topology");
        localCluster.shutdown();
    }
}

划重点：绝对不要用StormSubmitter.submitTopology()，这个方法是给远程Nimbus集群提交拓扑用的，本地模式必须用LocalCluster类来管理拓扑。

2. 检查Maven Exec插件的配置 #

确保你的pom.xml里的exec插件正确指向拓扑主类，没有多余的远程集群参数。示例配置如下：

<build>
    <plugins>
        <plugin>
            <groupId>org.codehaus.mojo</groupId>
            <artifactId>exec-maven-plugin</artifactId>
            <version>3.1.0</version>
            <executions>
                <execution>
                    <goals>
                        <goal>java</goal>
                    </goals>
                </execution>
            </executions>
            <configuration>
                <!-- 替换成你的拓扑主类全路径 -->
                <mainClass>com.yourpackage.ExclamationTopology</mainClass>
            </configuration>
        </plugin>
    </plugins>
</build>

3. 用正确的Maven命令启动 #

在IDE的终端里运行以下命令启动拓扑：

mvn exec:java

如果你的pom.xml里有多个exec配置，也可以直接指定主类运行：

mvn exec:java -Dexec.mainClass="com.yourpackage.ExclamationTopology"

4. 验证Storm依赖配置 #

确保pom.xml里的Storm核心依赖版本正确，并且本地运行的scope设置合理：

<dependencies>
    <dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-core</artifactId>
        <version>2.4.0</version>
        <!-- 本地运行时不需要打包到jar，设为provided即可 -->
        <scope>provided</scope>
    </dependency>
</dependencies>

如果之后需要打包成可执行jar在本地运行，可以去掉<scope>provided</scope>，但内存模式用LocalCluster的话，这个配置完全没问题。

额外排查点 #

• 确认本地没有手动启动过Storm的Nimbus服务，避免端口冲突（内存模式不需要单独启动Nimbus）；
• 查看IDE控制台的完整日志，有没有依赖缺失、端口被占用等其他错误，这些也可能间接导致Nimbus连接异常。

内容的提问来源于stack exchange，提问作者TechCrap