当Kafka从2.3更新到2.4时,关于spark需要考虑什么(如果有的话)?会不会影响现有的spark版本?
bxpogfeg1#
我正在使用kafka代理使用kafka 2.4客户端使用spark 2.1生成的一些消息我认为spark 2.4将支持kafka 2.4(您可以在本地安装它们,并尝试生成/使用helloworld主题)如果您对sbt相关性感兴趣:
val sparkVersion21 = "2.1.0" lazy val dependencies = Seq( "org.apache.spark" %% "spark-core" % sparkVersion21, "org.apache.spark" %% "spark-sql" % sparkVersion21, "org.apache.spark" %% "spark-hive" % sparkVersion21, "org.apache.spark" %% "spark-yarn" % sparkVersion21, "org.apache.kafka" % "kafka-clients" % "2.4.0", "org.apache.kafka" %% "kafka" % "2.4.0", "org.apache.kafka" % "kafka-streams" % "2.4.0")
1条答案
按热度按时间bxpogfeg1#
我正在使用kafka代理使用kafka 2.4客户端使用spark 2.1生成的一些消息我认为spark 2.4将支持kafka 2.4(您可以在本地安装它们,并尝试生成/使用helloworld主题)
如果您对sbt相关性感兴趣: