org.springframework.integration.kafka.listener
Class KafkaTopicOffsetManager.Key

java.lang.Object
  extended by 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


Constructor Summary
KafkaTopicOffsetManager.Key(java.lang.String consumerID, Partition partition)
           
 
Method Summary
 boolean equals(java.lang.Object o)
           
 java.lang.String getConsumerId()
           
 Partition getPartition()
           
 int hashCode()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KafkaTopicOffsetManager.Key

public KafkaTopicOffsetManager.Key(java.lang.String consumerID,
                                   Partition partition)
Method Detail

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