File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
external/kafka/src/main/scala/org/apache/spark/streaming/kafka Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -171,7 +171,7 @@ object KafkaUtils {
171171 sc : SparkContext ,
172172 kafkaParams : Map [String , String ],
173173 offsetRanges : Array [OffsetRange ]
174- ): RDD [(K , V )] with HasOffsetRanges = {
174+ ): RDD [(K , V )] = {
175175 val messageHandler = (mmd : MessageAndMetadata [K , V ]) => (mmd.key, mmd.message)
176176 val kc = new KafkaCluster (kafkaParams)
177177 val topics = offsetRanges.map(o => TopicAndPartition (o.topic, o.partition)).toSet
@@ -207,7 +207,7 @@ object KafkaUtils {
207207 offsetRanges : Array [OffsetRange ],
208208 leaders : Array [Leader ],
209209 messageHandler : MessageAndMetadata [K , V ] => R
210- ): RDD [R ] with HasOffsetRanges = {
210+ ): RDD [R ] = {
211211
212212 val leaderMap = leaders
213213 .map(l => TopicAndPartition (l.topic, l.partition) -> (l.host, l.port))
You can’t perform that action at this time.
0 commit comments