Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/20572#discussion_r169491061
--- Diff:
external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala
---
@@ -22,12 +22,17 @@ import java.{ util => ju }
import scala.collection.JavaConverters._
import scala.util.Random
+import kafka.common.TopicAndPartition
--- End diff --
These are the older Kafka APIs right? this may all be correct, just making
sure these are the classes that are needed in a Kafka 0.10 test?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
