Package io.aiven.commons.kafka.connector.source

Interface OffsetManager.OffsetManagerKey

Enclosing class:
OffsetManager
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface OffsetManager.OffsetManagerKey
The OffsetManager Key. Must override hashCode() and equals().

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,Object>
    getPartitionMap()
    Gets the partition map used by Kafka to identify this Offset entry.

  • Method Details

    • getPartitionMap

      Map<String,Object> getPartitionMap()
      Gets the partition map used by Kafka to identify this Offset entry. This is analogous to the sourcePartition in the kafka SourceRecord it represents a single input sourcePartition that the record came from (e.g. a filename, table name, or topic-partition). In most cases this should be a map representation of the NativeKey.

      Kafka stores all numbers as longs and so all keys based off integers should be created as longs in the manager key.

      This method should make a copy of the internal data and return that to prevent any accidental updates to the internal data.

      Returns:
      The partition map used by Kafka to identify this Offset entry.