diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md index d1faeaa081eb3..522e669568678 100644 --- a/docs/structured-streaming-kafka-integration.md +++ b/docs/structured-streaming-kafka-integration.md @@ -328,7 +328,7 @@ The following configurations are optional: {"topicA":{"0":23,"1":-1},"topicB":{"0":-1}} latest - batch only + batch query The end point when a batch query is ended, either "latest" which is just referred to the latest, or a json string specifying an ending offset for each TopicPartition. In the json, -1 as an offset can be used to refer to latest, and -2 (earliest) as an offset is not allowed. @@ -337,10 +337,11 @@ The following configurations are optional: failOnDataLoss true or false true - streaming only + streaming query Whether to fail the query when it's possible that data is lost (e.g., topics are deleted, or offsets are out of range). This may be a false alarm. You can disable it when it doesn't work - as you expected. + as you expected. Batch queries will always fail if it fails to read any data from the provided + offsets due to lost data. kafkaConsumer.pollTimeoutMs