File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010 Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -99,7 +99,7 @@ private case class Subscribe[K, V](
99
99
} catch {
100
100
case x : NoOffsetForPartitionException if shouldSuppress =>
101
101
logWarning(" Catching NoOffsetForPartitionException since " +
102
- ConsumerConfig .AUTO_OFFSET_RESET_CONFIG + " is none. See KAFKA-3370" )
102
+ ConsumerConfig .AUTO_OFFSET_RESET_CONFIG + " is none. See KAFKA-3370" )
103
103
}
104
104
toSeek.asScala.foreach { case (topicPartition, offset) =>
105
105
consumer.seek(topicPartition, offset)
@@ -149,7 +149,7 @@ private case class SubscribePattern[K, V](
149
149
} catch {
150
150
case x : NoOffsetForPartitionException if shouldSuppress =>
151
151
logWarning(" Catching NoOffsetForPartitionException since " +
152
- ConsumerConfig .AUTO_OFFSET_RESET_CONFIG + " is none. See KAFKA-3370" )
152
+ ConsumerConfig .AUTO_OFFSET_RESET_CONFIG + " is none. See KAFKA-3370" )
153
153
}
154
154
toSeek.asScala.foreach { case (topicPartition, offset) =>
155
155
consumer.seek(topicPartition, offset)
You can’t perform that action at this time.
0 commit comments