在storm群集上部署拓扑时出错

busg9geu 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(402)

我正在尝试在storm clustre上部署一个简单的字数拓扑。我使用kafka作为输入（kafka喷口）。这是我得到的错误
java.lang.noclassdeffounderror:无法初始化org.apache.log4j.log4jloggerfactory中的类org.apache.log4j.logger.getlogger（logger）。java:39)在kafka.utils.logging$class.logger（logging。scala:24)在kafka.consumer.simpleconsumer.logger$lzycompute（simpleconsumer。scala:30)在kafka.consumer.simpleconsumer.logger（simpleconsumer。scala:30)在kafka.utils.logging$class.info（logging。scala:67)在kafka.consumer.simpleconsumer.info（simpleconsumer。scala:30)在kafka.consumer.simpleconsumer.liftedtree1$1（simpleconsumer。scala:74)在kafka.consumer.simpleconsumer.kafka$consumer$simpleconsumer$$sendrequest（simpleconsumer。scala:68)在kafka.consumer.simpleconsumer.getoffsetsbefore（simpleconsumer。scala:127)在kafka.javaapi.consumer.simpleconsumer.getoffsetsbefore（simpleconsumer。scala:79)在Storm中。Kafka。Kafka提尔。getoffset（Kafka提尔。java:77)在Storm中。Kafka。Kafka提尔。getoffset（Kafka提尔。java:67)在Storm中。Kafka。分区经理。（分区经理。java:83)在storm.kafka.zkcoordinator.refresh（zkcoordinator。java:98)在storm.kafka.zkcoordinator.getmymanagedpartitions（zkcoordinator。java:69)在Storm中。Kafka。Kafka普特。下一次（Kafka普特。java:135)在backtype.storm.daemon.executor$fn\uuu4654$fn\uu4669$fn\uu4698.invoke（executor。clj:565)在backtype.storm.util$async\u loop$fn\u 458.invoke（util。clj:463)在clojure.lang.afn.run（afn。java:24)在java.lang.thread.run（线程。java:745)

Java apache-kafka Logging apache-storm

来源：https://stackoverflow.com/questions/30434639/error-while-deploying-topology-on-storm-cluster

2条答案

按热度按时间

mlnl4t2r1#

通过在我的storm库中添加log4j-over-slf4j-1.6.6.jar解决了这个问题。

赞(0）回复(0）举报 2021-06-08

zd287kbt2#

我正在使用
风暴0.9.6
Kafka0.9.0
风暴0.9.6，使用slf4j。所以你需要从你的Kafka参考中排除它，并包括log4j。下面是我的pom.xml

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.10</artifactId>
    <version>0.9.0.0</version>
    <exclusions>
        <exclusion>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </exclusion>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <!--<exclusion>-->
            <!--<groupId>log4j</groupId>-->
            <!--<artifactId>log4j</artifactId>-->
        <!--</exclusion>-->
    </exclusions>
</dependency>

赞(0）回复(0）举报 2021-06-08

我来回答

在storm群集上部署拓扑时出错

2条答案

相关问题

热门标签

最新问答