We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0894aef commit 16bfe78Copy full SHA for 16bfe78
external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaReceiver.scala
@@ -17,12 +17,12 @@
17
18
package org.apache.spark.streaming.kafka
19
20
-import scala.collection.Map
21
-import scala.reflect.{classTag, ClassTag}
22
-
23
import java.util.Properties
24
import java.util.concurrent.Executors
25
+import scala.collection.Map
+import scala.reflect.{classTag, ClassTag}
+
26
import kafka.consumer._
27
import kafka.serializer.Decoder
28
import kafka.utils.VerifiableProperties
0 commit comments