pyspark 是否支持 spark-streaming-kafka-0-10 lib？答案

【问题标题】：does pyspark support spark-streaming-kafka-0-10 lib?pyspark 是否支持 spark-streaming-kafka-0-10 lib？
【发布时间】：2018-01-13 07:09:48
【问题描述】：

我的 kafka 集群版本是 0.10.0.0，我想使用 pyspark 流来读取 kafka 数据。但在 Spark Streaming + Kafka 集成指南中，http://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html 没有python代码示例。那么pyspark可以使用spark-streaming-kafka-0-10来集成kafka吗？

提前感谢您的帮助！

【问题讨论】：

标签： pyspark apache-kafka spark-streaming-kafka

【解决方案1】：

我还将火花流与 Kafka 0.10.0 集群一起使用。在您的代码中添加以下行后，您就可以开始了。

spark.jars.packages org.apache.spark:spark-streaming-kafka-0-8_2.11:2.0.0

这里有一个python示例：

# Initialize SparkContext
sc = SparkContext(appName="sampleKafka")

# Initialize spark stream context
batchInterval = 10
ssc = StreamingContext(sc, batchInterval)

# Set kafka topic
topic = {"myTopic": 1}

# Set application groupId
groupId = "myTopic"

# Set zookeeper parameter
zkQuorum = "zookeeperhostname:2181"

# Create Kafka stream 
kafkaStream = KafkaUtils.createStream(ssc, zkQuorum, groupId, topic)

#Do as you wish with your stream
# Start stream
ssc.start()
ssc.awaitTermination()

【讨论】：

您使用的是 spark-streaming-kafka-0.8 而不是 0.10，正如您根据软件包所说的那样

【解决方案2】：

当您的代理为 0.10 及更高版本时，您可以使用 spark-streaming-kafka-0-8。 spark-streaming-kafka-0-8 支持较新的代理版本，而 streaming-kafka-0-10 不支持较旧的代理版本。截至目前，streaming-kafka-0-10 仍处于试验阶段，不支持 Python。

【讨论】：