我想获得帮助的初始设置与apachestorm和kafka设置。
我可以向storm集群提交拓扑,但在storm ui中出现以下错误。(KafkaOffsetLagUtil.java:387) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOffsetLags(KafkaOffsetLagUtil.java:268) at org.apache.storm</
我正在使用项目。我正在当地经营这个项目。它正在抛出跟随错误。(DynamicBrokersReader.java:81) ~[storm-kafka-0.9.2-incubating.jar:0.9.2-incubating]
at storm.kafka.trident.ZkBrokerReader<init>(ZkBrokerReader.java:42) ~[storm-kafka-0.9.2-incubating.jar:0.9.2-incu
OffsetRequest at org.apache.storm.kafka.trident.TridentKafkaConfig.AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java