Skip to content

KafkaSourceOffset

KafkaSourceOffset is an Offset in Kafka Data Source.

Creating Instance

KafkaSourceOffset takes the following to be created:

  • Offsets by Partitions (Map[TopicPartition, Long])

KafkaSourceOffset is created when:

Creating KafkaSourceOffset Instance

apply(
  offsetTuples: (String, Int, Long)*): KafkaSourceOffset
apply(
  offset: SerializedOffset): KafkaSourceOffset
apply(
  offset: Offset): KafkaSourceOffset

apply creates a KafkaSourceOffset.


apply is used when:

Partition Offsets

getPartitionOffsets(
  offset: Offset): Map[TopicPartition, Long]

getPartitionOffsets requests the given KafkaSourceOffset or SerializedOffset (from the given Offset) for the partitionToOffsets.


getPartitionOffsets is used when: