解决java.lang.ClassNotFoundException: storm.kafka.BrokerHosts问题

问题描述

maven编译storm+kafka的AdvertisingTopology项目后进行提交时,出现如下异常信息:

image

问题解决

问题原因是因为storm-kafka依赖没有被maven编译到jar文件中。pom.xml中的storm-kafka依赖修改为:

            <dependency>
                <groupId>org.apache.storm</groupId>
                <artifactId>storm-kafka</artifactId>
                <version>${storm.version}</version>
                <!--<scope>provided</scope>-->
            </dependency>

其中将<scope>项注释掉后,重新编译提交即可以正常提交。