Options¶

includeHeaders¶

default: false

startingOffsets¶

Specifies where to start reading records

Only applies to new streaming queries that start from scratch (resuming will always pick up from where a query left off)

default: false

Supported values:

• earliest
• latest

Used when:

• KafkaSourceProvider is requested to createSource (to getKafkaOffsetRangeLimit), createRelation, validateBatchOptions
• KafkaScan is requested to toBatch, toMicroBatchStream, toContinuousStream