Github user gaborgsomogyi closed the pull request at:
https://github.com/apache/spark/pull/20703
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user gaborgsomogyi commented on a diff in the pull request:
https://github.com/apache/spark/pull/20703#discussion_r171741027
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchReader.scala
---
@@ -76,6 +76,10 @@ private[kafka010]
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/20703#discussion_r171690388
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchReader.scala
---
@@ -76,6 +76,10 @@ private[kafka010] class
Github user gaborgsomogyi commented on a diff in the pull request:
https://github.com/apache/spark/pull/20703#discussion_r171665564
--- Diff: docs/structured-streaming-kafka-integration.md ---
@@ -376,6 +383,8 @@ The following configurations are optional:
+If
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20703#discussion_r171648378
--- Diff: docs/structured-streaming-kafka-integration.md ---
@@ -376,6 +383,8 @@ The following configurations are optional:
+If
GitHub user gaborgsomogyi opened a pull request:
https://github.com/apache/spark/pull/20703
[SPARK-19185][SS] Make Kafka consumer cache configurable
## What changes were proposed in this pull request?
Use property `spark.streaming.kafka.consumer.cache.enabled` in structured
