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

Class OffsetManager.OffsetManagerKey

java.lang.Object

io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerKey

Enclosing class:

OffsetManager

public static final class OffsetManager.OffsetManagerKey
extends Object

The OffsetManager Key. Implements a segmented key. Key segments are presented in lexical order.

Constructor Summary

Constructors

Constructor	Description
OffsetManagerKey(Map<String,?> map)	Constructs the OffsetManagerKey from the provided map.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Map<String,Object>	getPartitionMap()	Retrieve the partition map for a Kafka Source record.
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OffsetManagerKey

public OffsetManagerKey(Map<String,?> map)

Constructs the OffsetManagerKey from the provided map.

Parameters:

map - the map to copy the key/value segments from.

Method Details

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

getPartitionMap

public Map<String,Object> getPartitionMap()

Retrieve the partition map for a Kafka Source record.

Returns:

The partition map for a Kafka Source record.