diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md index 0ec359f800..6121f19e80 100644 --- a/docs/structured-streaming-kafka-integration.md +++ b/docs/structured-streaming-kafka-integration.md @@ -547,10 +547,10 @@ The following configurations are optional: "error" or "latest" "error" streaming and batch - Defines the behavior when the starting offset by timestamp is specified (either global or per partition), and Kafka doesn't return the matched offset.

+ The strategy will be used when the specified starting offset by timestamp (either global or per partition) doesn't match with the offset Kafka returned. Here's the strategy name and corresponding descriptions:

- "error": fail the query.

- "latest": set the offset to the latest, so that further new records in the partition are being read.

+ "error": fail the query and end users have to deal with workarounds requiring manual steps.

+ "latest": assigns the latest offset for these partitions, so that Spark can read newer records from these partitions in further micro-batches.