org.springframework.integration.kafka.listener
Class KafkaTopicOffsetManager.Key
java.lang.Object
org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
- Enclosing class:
- KafkaTopicOffsetManager
public static class KafkaTopicOffsetManager.Key
- extends java.lang.Object
Wraps the partition and consumer information and will be used as a key on the Kafka topic
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
KafkaTopicOffsetManager.Key
public KafkaTopicOffsetManager.Key(java.lang.String consumerID,
Partition partition)
getConsumerId
public java.lang.String getConsumerId()
getPartition
public Partition getPartition()
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in class java.lang.Object
hashCode
public int hashCode()
- Overrides:
hashCode
in class java.lang.Object