Skip to content

Commit 0e2ca25

Browse files
committed
Address TD's comment
1 parent d9d3065 commit 0e2ca25

4 files changed

Lines changed: 4 additions & 4 deletions

File tree

docs/structured-streaming-kafka-integration.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,7 @@ The following configurations are optional:
392392
source has its own consumer group that does not face interference from any other consumer, and
393393
therefore can read all of the partitions of its subscribed topics. In some scenarios (for example,
394394
Kafka group-based authorization), you may want to use a specific authorized group id to read data.
395-
You can optionally set the group ID. However, do this with extreme caution as it can cause
395+
You can optionally set the group id. However, do this with extreme caution as it can cause
396396
unexpected behavior. Concurrently running queries (both, batch and streaming) or sources with the
397397
same group id are likely interfere with each other causing each query to read only part of the
398398
data. This may also occur when queries are started/restarted in quick succession. To minimize such

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReadSupport.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ class KafkaContinuousScanConfigBuilder(
171171
offsetReader.driverKafkaParams.containsKey(ConsumerConfig.GROUP_ID_CONFIG)) {
172172
s"$deletedPartitions are gone. ${KafkaSourceProvider.CUSTOM_GROUP_ID_ERROR_MESSAGE}"
173173
} else {
174-
s"$deletedPartitions are gone. Some data may have been missed"
174+
s"$deletedPartitions are gone. Some data may have been missed."
175175
}
176176
reportDataLoss(message)
177177
}

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchReadSupport.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ private[kafka010] class KafkaMicroBatchReadSupport(
127127
if (kafkaOffsetReader.driverKafkaParams.containsKey(ConsumerConfig.GROUP_ID_CONFIG)) {
128128
s"$deletedPartitions are gone. ${KafkaSourceProvider.CUSTOM_GROUP_ID_ERROR_MESSAGE}"
129129
} else {
130-
s"$deletedPartitions are gone. Some data may have been missed"
130+
s"$deletedPartitions are gone. Some data may have been missed."
131131
}
132132
reportDataLoss(message)
133133
}

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,7 @@ private[kafka010] class KafkaSource(
245245
val message = if (kafkaReader.driverKafkaParams.containsKey(ConsumerConfig.GROUP_ID_CONFIG)) {
246246
s"$deletedPartitions are gone. ${KafkaSourceProvider.CUSTOM_GROUP_ID_ERROR_MESSAGE}"
247247
} else {
248-
s"$deletedPartitions are gone. Some data may have been missed"
248+
s"$deletedPartitions are gone. Some data may have been missed."
249249
}
250250
reportDataLoss(message)
251251
}

0 commit comments

Comments
 (0)