Skip to content
Snippets Groups Projects
Commit 4d040297 authored by manugarri's avatar manugarri Committed by Shixiong Zhu
Browse files

[MINOR][DOC] Remove parenthesis in readStream() on kafka structured streaming doc

There is a typo in http://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html#creating-a-kafka-source-stream

 , python example n1 uses `readStream()` instead of `readStream`

Just removed the parenthesis.

Author: manugarri <manuel.garrido.pena@gmail.com>

Closes #16836 from manugarri/fix_kafka_python_doc.

(cherry picked from commit 5a0569ce)
Signed-off-by: default avatarShixiong Zhu <shixiong@databricks.com>
parent 706d6c15
No related branches found
No related tags found
No related merge requests found
...@@ -90,7 +90,7 @@ ds3.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)") ...@@ -90,7 +90,7 @@ ds3.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)")
# Subscribe to 1 topic # Subscribe to 1 topic
ds1 = spark ds1 = spark
.readStream() .readStream
.format("kafka") .format("kafka")
.option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("kafka.bootstrap.servers", "host1:port1,host2:port2")
.option("subscribe", "topic1") .option("subscribe", "topic1")
...@@ -108,7 +108,7 @@ ds2.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)") ...@@ -108,7 +108,7 @@ ds2.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)")
# Subscribe to a pattern # Subscribe to a pattern
ds3 = spark ds3 = spark
.readStream() .readStream
.format("kafka") .format("kafka")
.option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("kafka.bootstrap.servers", "host1:port1,host2:port2")
.option("subscribePattern", "topic.*") .option("subscribePattern", "topic.*")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment