Skip to content

Offset — Read Position of Streaming Query

Offset is an abstraction of stream positions.

Note

There are two Offset abstractions and new streaming data sources should use Data Source v2 API.

Contract

JSON Representation

String json()

JSON-encoded representation of the offset

Used when:

Implementations

  • ContinuousMemoryStreamOffset
  • FileStreamSourceOffset
  • KafkaSourceOffset
  • LongOffset
  • SerializedOffset
  • TextSocketOffset