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;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.common.serialization.StringDeserializer;
--- End diff --
I think this import should be moved to above?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
