Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/21717
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user cluo512 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21717#discussion_r200306144
--- Diff:
examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java
---
@@ -50,25 +52,30 @@
private static final Patt
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21717#discussion_r200299285
--- Diff:
examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java
---
@@ -50,25 +52,30 @@
private static final Patte
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21717#discussion_r200289077
--- Diff:
examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java
---
@@ -50,25 +52,30 @@
private static final Patte
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21717#discussion_r200288285
--- Diff:
examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java
---
@@ -26,8 +26,10 @@
import scala.Tuple2;
GitHub user cluo512 opened a pull request:
https://github.com/apache/spark/pull/21717
[SPARK-24743] [Examples]Update the JavaDirectKafkaWordCount example to
support the new API of kafka
## What changes were proposed in this pull request?
Add some required configs for Kafka
