回答情况：
提问时间：
问题标签：
我在Java8中使用Spark Streaming和spark-streaming-kafka连接器(都是最新版本)谢谢你的帮助。
浏览 1修改于2019-09-18得票数 2
dependency>
这个问题出现在KafkaUtils.createDirectStream()中，我检查了maven和scala兼容性，JDK 11与Scala2.12及更高版本兼容，而且我们对spark-streaming-kafkaKIndly让我知道我的分析是否错误，我应该为JDK 11的spark-streaming-kafka使用哪个jar
浏览 4修改于2021-06-07得票数 0
logstash-logback-encoder" % "4.6", "org.apache.spark" %% "spark-streaming-kafka" % "1.6.1",
("org.apache.spark" %% "spark-streaming-
浏览 0提问于2016-04-08得票数 2
回答已采纳
Utils.settings.kafkaGroup, Utils.settings.topicMapWifi) libraryDependencies += "org.apache.spark" %% "spark-streaming-kafka
浏览 5提问于2016-04-24得票数 0
org.apache.spark" %% "spark-streaming" % "1.6.0" % "provided"
libraryDependencies += "org.apache.spark" %% "spark-streaming-kafka
浏览 2修改于2019-10-20得票数 0
我使用spark-streaming-kafka检查点将处理后的Kafka偏移量存储到HDFS中的文件夹中，在重启应用程序(使用spark-submit)以检查恢复后，我在一个属于spark-streaming-kafka
浏览 1修改于2015-12-03得票数 1
consumer开始限制每批(5秒)读取450个事件(5 * 90个分区)，在此之前运行了1到2天(每批约5000到40000个事件)
我使用在亚马逊网络服务中运行的spark独立集群(spark和spark-streaming-kafka
浏览 2修改于2016-12-19得票数 2
org.apache.spark" %% "spark-streaming" % "1.5.2" % "provided";
libraryDependencies += "org.apache.spark" %% "spark-streaming-kafka
浏览 7提问于2017-01-06得票数 2
spark-core" % "1.2.0", "org.apache.spark" %% "spark-streaming-kafka
浏览 8提问于2015-08-25得票数 3
spark-cassandra-connector" % "1.6.2",("org.apache.spark" %% "spark-streaming-kafka
浏览 3修改于2022-08-17得票数 0
回答已采纳
.`我使用了spark-streaming-kafka的所有类库，但都不起作用：
我正在执行spark shell中的代码
浏览 4修改于2018-07-05得票数 1
spark-streaming-kafka版本为0-10_2.11-2.3.0。 PAYOAD列中的JSON数据是我想要处理和分析的。如何更改代码以获取JSON数据
浏览 26修改于2019-04-15得票数 2
spark-hive" % "1.6.0", "org.apache.spark" %% "spark-streaming-kafka
浏览 5修改于2018-12-25得票数 10
"org.apache.spark" %% "spark-streaming" % sparkVersion % "provided",
"org.apache.spark" %% "spark-streaming-kafka
浏览 5修改于2016-12-06得票数 3
回答已采纳
1回答
libraryDependencies += "org.apache.spark" %% "spark-core" % "1.4.1"
libraryDependencies += "org.apache.spark" %% "spark-streaming-kafka
浏览 1修改于2016-01-16得票数 2
/external/spark-streaming-kafka*.jar examples/src/main/python/streaming/kafka_wordcount.py localhost:
浏览 4提问于2017-09-20得票数 1
回答已采纳
-- https://mvnrepository.com/artifact/org.apache.spark/spark-streaming-kafka --><dependency>
<groupId
浏览 7修改于2018-12-07得票数 0
org.apache.spark" %% "spark-streaming" % "2.4.0" % "provided"
libraryDependencies += "org.apache.spark" %% "spark-streaming-kafka
浏览 8提问于2019-11-14得票数 1
回答已采纳
spark-core" % "1.1.1", "org.apache.spark" %% "spark-streaming-kafka
浏览 6修改于2017-05-23得票数 11
回答已采纳
version := "0.0.1"
"org.apache.spark" %% "spark-streaming-kafka
浏览 2修改于2015-07-04得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号