当Kafka从2.3升级到2.4时，关于Spark需要考虑什么(如果有)？它会影响现有的Spark版本吗？
浏览 38提问于2020-01-17得票数 0
1回答
我正在尝试在Scala中运行一个Spark应用程序来连接到ActiveMQ。我可以在我的Spark-Structured-Streaming中使用Bahir的替代方案来连接到ActiveMQ主题吗？编辑: my build.sbt //For spark "org.apache.spark" %% "spark-core" % "2.4.0"
浏览 24提问于2020-12-09得票数 1
回答已采纳
我无法使用Python语言中的以下代码从spark_2.4.4结构化流连接到kafka_2.12-2.3.0。\ .getOrCreate()
.readStream\$spark-submit --jars /opt/hadoop/spark/jars/
浏览 17提问于2019-10-23得票数 0
回答已采纳
我将Spark 2.4与Hive Warehouse Connector和Scala 2.11结合使用。目前由Hortonworks提供的蜂巢仓库连接器与Spark2.4不兼容。因此，我从编译了jar文件，这使得它与Spark2.4兼容。
我的Spark应用程序从Kafka输入流读取，并使用Hive Warehouse连接器提供的Hive输出流写入Hive表(ORC格式)。.format("
浏览 1提问于2020-04-01得票数 3
我刚接触apache camel和apache kafka，并为我的项目做了一个小POC。当我尝试使用Camel-kafka组件从kafka读取时，我得到了以下问题错误日志。(kafka.network.Processor) at kafka.network.MultiSend.
浏览 0提问于2016-01-20得票数 0
.InternalKafkaConsumer.org$apache$spark$sql$kafka010$InternalKafkaConsumer$$fetchData(KafkaDataConsumer.scala:109)
at org.apache.spark.sql.kafka010.InternalKafkaConsumer.get(KafkaDataConsumer.scala:147)at org.apache.spark.sql.kafka010.Kaf
浏览 5提问于2021-06-28得票数 1
1回答
我使用Spring Kafka的KafkaTemplate来发送消息。org.apache.kafka.common.security.ssl.SslFactory.sslEngineBuilder()Lorg/apache/kafka/common/security/在属性文件中，我有以下值 spring.kafka.properties.basic.auth.credentials.source=USER_INFO
spring.kafka.prope
浏览 45提问于2021-05-05得票数 0
回答已采纳
我有以下情况，这不是maven- following ()所涵盖的：scala-2.11scala-2.12spark-2.2spark-2.3spark-2.4Scala2.11和2.12必须是activatedexact activatedspark 2.2中的一个，2.3和2.4必须是 2.2和2.3不兼容Scala2.12
现有的maven插件太弱，无法实现这一点。我还有
浏览 2提问于2019-10-01得票数 1
1回答
在我的Spark工作中，我用KafkaUtils.createDirectStream初始化Kafka流。
我读到过Consumer的seekToEnd方法。如何将其应用于流？
浏览 12提问于2020-03-11得票数 1
我是java和bigdata的新手，java依赖关系管理非常糟糕，因为me.You必须猜测应该使用哪个包和版本，如果第三方库什么都不告诉您，哪个包会发生冲突。"local[2]") return spark.readStream().format("kafka")(Config.KAFKA_JKS))
.option("kafka</em
浏览 6提问于2019-11-17得票数 1
2回答
我刚刚复制了星火流wodcount python代码，并在spark集群中使用火花提交运行wordcount python代码，但它显示了以下错误：: java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelperjava.security.AccessController.
浏览 3提问于2015-04-07得票数 1
回答已采纳
util.ShutdownHookManager: Shutdown hook called21/07/21 12:28:09 INFO util.ShutdownHookManager: Deleting directory /tmp/spark-a0c7670a-a
浏览 9提问于2021-07-21得票数 1
Spark的哪些版本与Sparklyr兼容，有权威来源吗？或者，有谁能阐明如何确定这一点？我使用的是macOS，但使用Spark2.4.x并不成功；它们都无法连接，通常会产生一个"Failed to connect to sparklyr to port 8880...“错误。Find available versions, using spark_available_versions() 可用的版本包括： > spark_available_versi
浏览 15提问于2019-05-17得票数 0
回答已采纳
我可以在没有星火流的情况下读到卡夫卡的消息吗？我的意思是，仅与火花核心库的批处理的目的。如果可以，请举几个例子。我正在使用HDP 2.4，Kafka 0.9和Spark1.6。
浏览 2提问于2016-10-12得票数 2
我是一个新的在大数据领域的初学者，我需要做一个演示，从卡夫卡主题流使用火花流数据，然后做一些聚合和过滤，然后保存这些数据。我正在使用spark 2.3，我需要知道哪个版本的spark stream Kafka必须使用0.8或10，就像在spark-2.3文档->中一样
提到0.8是稳定的，10是实验性的，我使用的是Kafka 2.1。
浏览 5提问于2019-03-17得票数 1
1回答
我试着和卡夫卡经纪人一起用日志。它不能集成在一起。每个版本都是，
input { } output{ codec => rubydebug bootstrap_servers => 10.120.16.202:6667,10.120.16.203
浏览 2提问于2016-10-09得票数 2
下面是我使用Spark结构化流从Kafka读取数据的代码，val df = ss .format("kafka")
.option("kafka.bootstrap.servers", kafka_server)libraryDependencies += "org.apache.spark"
浏览 0提问于2018-03-28得票数 6
回答已采纳
1回答
我试着安装了不同版本的火花放电和火花-nlp库。import sparknlpspark.version
#download, load, and annotate a text by pre-trained
浏览 7提问于2019-10-23得票数 7
我正在用和scala在Intellij中创建Maven项目。但是Intellij无法识别火花会话、火花上下文和sqlcontext。图像随函附上。它是一个XML文件，包含有关Maven用于构建项目的项目和配置细节的信息。我的POM文件是这样的。 <avro.version>1.7.7</avro.version>
浏览 2提问于2020-06-25得票数 1
回答已采纳
我是斯派克和Python的新手。我在windows上安装了python 3.5.1和Spark-1.6.0-bin-hadoop2.4。你能帮忙吗？-1.6.0-bin-hadoop2.4\python\pyspark\context.py"，第112行，在init中文件"C:\spark-1.6.0-bin-hadoop2.4<
浏览 4提问于2016-02-17得票数 8
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
