我正在尝试将Storm拓扑提交到群集，但不断收到相同的错误： Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequestCaus
浏览 23提问于2020-01-28得票数 1
回答已采纳
1回答
:1.7.13', 'org.apache.storm:storm-kafka/gradlew run时，我得到：
Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api
浏览 3提问于2015-11-30得票数 1
回答已采纳
1回答
java.lang.NoClassDefFoundError: org/I0Itec/zkclient/serialize/ZkSerializerat kafka.network.BoundedByteBufferSend.(Simple
浏览 0提问于2014-02-20得票数 0
在使用新的Kafka版本2.1.0和Storm版本1.2.2开始使用Kafka Spout开始拓扑时，获得了一个java.lang.ClassNotFoundException: kafka.api.OffsetRequest当我使用Kafka版本0.10.0.1时，我没有得到这个。你们能帮帮忙吗，因为我想上最新的Kafka版本？ 我已经尝试了所有最新的kafka版本，从2.*开始。但不是works.Caused by: java.l
浏览 16提问于2019-02-07得票数 0
回答已采纳
1回答
我可以用本地集群运行storm Kafka，但不能用storm Submitter运行下面是我的拓扑代码package com.org.kafka;
import org.apache.storm.kafka.KafkaSpout;import org
浏览 6提问于2018-01-24得票数 0
当我尝试将Kafka集成到我们的暴风拓扑时，我得到了错误的java.lang.ClassNotFoundException kafka.api.OffsetRequest。我的pom.xml <groupId>org.apache.storm</groupId> &l
浏览 0提问于2015-07-20得票数 4
我正在将一个应用程序从Kafka 0.7转换为Kafka 0.8，我不得不为一个简单的用户使用新的API。在这样做的过程中，我遵循了示例，并从我们当前的实现转换为API。然而，当创建一个OffsetRequest对象时，示例传递一个字符串作为第三个参数，我从apache中提取的jar期待一个名为“复制”的arg类型的字符串，我找不到任何关于这个值是什么的文档，有人能解释它是什么吗如果有默认值，就像在其他类似的kafka上一样，我很感激知道它们是什么。
谢谢!
浏览 1提问于2014-06-25得票数 0
回答已采纳
Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequestat storm.kafka.trident.TridentKafkaConfig.com.intellij.rt.executi
浏览 5提问于2016-01-06得票数 3
回答已采纳
在我们的项目中，我们使用storm来处理实时的Kafka主题Storm-Kafka version: 1.0.2错误日志：
java.lang.NoClassDefFoundError: org/apache/kafka/common/requests/AbstractRespon
浏览 15提问于2017-11-24得票数 1
我有一个3节点的kafka集群设置。我正在使用storm来阅读来自kafka的消息。我的系统中的每个主题都有7个分区。 requestInfoMap.pu
浏览 0提问于2013-09-30得票数 5
我有storm-kafka-0.10.0.jar、kafka-0.6.jar、scala-library-2.10.3.jar和storm-core-0.10.0.jar作为外部jars。;import storm.kafka.SpoutConfig;
import storm.kafka<
浏览 0提问于2016-11-17得票数 0
topicName, "" , "test123");//spoutConfig.startOffsetTime = kafka.api.OffsetRequest.EarliestTime但是，如果使用: spoutConfig.startOffsetTime =kafka.api.OffsetRequest.EarliestTime()，则不会将
浏览 0提问于2015-06-17得票数 0
1回答
我想知道有没有Kafka Spout支持安全的Kafka Broker。来自apache storm的KafkaSpout不支持SSL。public KafkaSpout(SpoutConfig spoutConf) {} this(hosts, topic, k
浏览 3提问于2017-03-30得票数 1
1回答
卡夫卡喷口没有发出数据
、、、
我是卡夫卡和Storm.So的新手，我无法得到这个problem.Please建议的理由，提前modifications.Thanks！public class TopologyMain {
conf.put(Config.NIMBUS_THRIFT_PORT, 6627);
浏览 2提问于2015-05-25得票数 1
回答已采纳
我看到有一个，但它被注释为开发API。
有没有什么公开的方法来确定主题的最早和最新偏移量？
浏览 2提问于2016-05-02得票数 7
498) ~[na:1.7.0_71] at kafka.api.OffsetResponse:77) ~[storm-kafka-0.9.3.jar:0.9.3]
at storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:67) ~[storm-<
浏览 5提问于2015-01-15得票数 2
这是我的喷口配置： className: "org.apache.storm.kafka.ZkHosts" className: "kafka.api.OffsetRequest"
factory: &q
浏览 0提问于2018-05-28得票数 0
回答已采纳
我试图理解Clojure规范。在设置clojure项目时，我在需要clojure.spec.alpha时遇到以下错误：at clojure.lang.Compiler.load(Compiler.java:7391)
at clojure.lang.Compiler
浏览 6提问于2018-02-06得票数 11
我正在尝试使用storm - LocalCluster 1.0.2和kafka-spout 1.0.2来运行storm-Core1.0.2。-- Storm Kafka Dependency --> <groupId>org.apache.storm</groupId>storm jar</
浏览 5提问于2016-12-30得票数 1
:479) at clojure.lang.AFn.run(( storm.kafka.KafkaUtils.fetchMessages(KafkaUtils.java:186) at storm.kafka.trident.TridentKafkaEmitter.fetchMessages:113) at storm.kafka.trident.TridentKafkaEmitter.failFastEmitNewPartitionBatch(TridentKafkaEmitter.j
浏览 1提问于2015-12-08得票数 1
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号