我认为这与存储库导入kafka相关包的方式有关。我正在使用scope和classifiers添加pom依赖项。 你能帮我修一下这个吗？<kafka-clients.version>0.10.2.1</kafka-clients.version>
<groupId>org.apache.kafka</groupId>
<artifact
浏览 151提问于2020-06-15得票数 1
回答已采纳
我想在Spring中使用Kafka客户端。我添加了maven依赖项。
<sprin
浏览 12提问于2019-12-03得票数 0
回答已采纳
我使用Kafka作为Flink job的数据源。当我将作业部署到flink集群作业管理器时，我收到一个错误ClassNotFoundException：Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource下面是我的pom.xml依赖项 <dependencies>
浏览 489提问于2021-08-28得票数 0
回答已采纳
1回答
我在我的项目中使用Kafka stream 2.3.0依赖项，但当我使用2.3.0构建JAR时，我看到2.0.1 Kafka版本并导致Kafka连接问题。我从来没有在我的代码中使用2.0.1，我想知道Kafka从哪里获得这个版本 <streams.version>2.3.0</streams.version><dependency>
&l
浏览 2提问于2020-08-13得票数 0
我正试图在docker上运行我的kafka项目。/clients/producer/ProducerCaused by: java.lang.ClassNotFoundException349) ... 1 more 我不确定，但它看起来不能从pom.xml加载<
浏览 50提问于2019-06-18得票数 0
回答已采纳
可能是因为依赖项冲突。pom.xml中的相关jars <groupId>org.apache.kafka</groupId>[INFO] +- org.apache.kafka:kafka-streams:jar:1.0.1:compile
[INFO] | \- org.apache.kafka:connect-j
浏览 36提问于2020-05-22得票数 0
我遵循以下spring文档@DirtiesContextlog.dir=/kafka-logslog.dir=real_path_to_my_project/kafka-logs...但是每次我运行测试时都会得到这个错误：
kafka.server.LogDirFailureChannel.error -
浏览 5提问于2019-10-13得票数 4
项目A的pom是一个简单的pom：<artifactId>kafka-demo</artifactId><name>kafka-demo</name> <parent>
<artifactId&g
浏览 3提问于2020-07-06得票数 2
回答已采纳
metrics/MetricsContext at tutorial4.StreamsFilterTweet.main(StreamsFilterTweet.java:35)中的异常由: java.lang.ClassNotFoundException根据堆栈跟踪，这一行造成了问题：我使用的是Maven，并具有以下依赖关系：
浏览 12提问于2020-11-19得票数 2
回答已采纳
1回答
我正在使用下面的代码从kafka主题中读取数据。os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages org.apache.spark:spark-streaming-kafka-0-10_2.12:3.1.3,org.apache.spark:spark-sql-kafka-0-10_2.12:3.1.3 pyspark-shell'
df = spark.readStream.format("kafka$sql$kaf
浏览 7提问于2022-03-30得票数 0
下面是mvn依赖项的输出:tree我看到它出现在两个地方，我想知道在运行应用程序时，哪个依赖项会起作用。tree (default-cli) @ suite ---[INFO] +- org.apache.kafka:kafka_2.11:jar:0.8.2-V3-PATCH:compile
[INFO] | +- org.scala-lang.modules:scala-x
浏览 0提问于2014-11-22得票数 2
回答已采纳
"0.9.5"] [org.apache.kafka/kafka:aot [kafka2hdfs.core])Compiling kafka2hdfs.core
java.lang.ClassNotFoundException: backtype.
浏览 3提问于2015-11-02得票数 1
回答已采纳
我使用以下依赖项：val kafkaVersion = "0.10.0.1"
"com.softwaremill.reactivekafka" %% "reactive-kafka-core", "kafka_2.11&qu
浏览 6提问于2016-09-06得票数 0
1回答
parameterTool.getProperties()));
env.execute();我用相同的代码在intellij中创建了一个独立的项目(有它自己的pommaven模块的pom.xml中的依赖项是： <project.build.sourceEncoding>UTF-8</project.build.sourceEncodingflink.version}</version>
浏览 0提问于2018-05-18得票数 2
回答已采纳
但是在使用命令ClassNotFoundException运行时，我得到了java -jar target/JarName.jar at com.package.App.main(App.java:26)import kaf
浏览 2提问于2015-08-11得票数 3
回答已采纳
这是我的pom.xml： <groupId>org.apache.poi</groupId> <version>3.9</version>这是我的错误信息：
java.lang.<e
浏览 2提问于2014-06-16得票数 0
回答已采纳
2回答
星火卡夫卡流媒体问题
、、、
我在用maven <dependency> <!-- Spark dependency --> <artifactId>spark-streaming-kafkaJavaSparkContext(sparkConf);
sc.addJar("/home/test/.m2/repository/org/
浏览 2提问于2014-09-18得票数 4
回答已采纳
当我尝试将Kafka集成到我们的暴风拓扑时，我得到了错误的java.lang.ClassNotFoundException kafka.api.OffsetRequest。我的pom.xml <groupId>org.apache.storm</groupId>
浏览 0提问于2015-07-20得票数 4
<version>2.2.0</version>但是我会看到一个错误:线程"main“java.lang.ClassNotFoundException中的异常:未能找到数据源: kafka。请在找到包裹
我知道我可以通过在星星之交之后添加--packages org.apache.spark:spark-sql-kafka-0-1
浏览 3提问于2017-08-21得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
