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](
9999 } catch {
100100 case x : NoOffsetForPartitionException if shouldSuppress =>
101101 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" )
103103 }
104104 toSeek.asScala.foreach { case (topicPartition, offset) =>
105105 consumer.seek(topicPartition, offset)
@@ -149,7 +149,7 @@ private case class SubscribePattern[K, V](
149149 } catch {
150150 case x : NoOffsetForPartitionException if shouldSuppress =>
151151 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" )
153153 }
154154 toSeek.asScala.foreach { case (topicPartition, offset) =>
155155 consumer.seek(topicPartition, offset)
You can’t perform that action at this time.
0 commit comments