擅长:python、mysql、java
<blockquote>
<p>I found some similarities at <a href="https://kafka-python.readthedocs.io" rel="nofollow noreferrer">https://kafka-python.readthedocs.io</a></p>
</blockquote>
<p>不过,那不是火花代码。Spark需要javakafkaapi的属性。你知道吗</p>
<p><a href="https://spark.apache.org/docs/2.4.4/streaming-kafka-integration.html" rel="nofollow noreferrer">^{<cd1>} is not available in Python</a>,但是如果您想使用Spark,这是0.8api,<a href="https://spark.apache.org/docs/2.4.4/streaming-kafka-0-8-integration.html" rel="nofollow noreferrer">which has Python examples</a></p>
<pre><code>from pyspark.streaming.kafka import KafkaUtils
# ssc = <get a StreamingContext>
directKafkaStream = KafkaUtils.createDirectStream(ssc, [topic], {"metadata.broker.list": brokers})
</code></pre>