Package io.aiven.kafka.connect.common.source

Interface OffsetManager.OffsetManagerKey

Enclosing class:

OffsetManager<E extends OffsetManager.OffsetManagerEntry<E>>

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.

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.