Package io.confluent.parallelconsumer.state

Class ShardKey.TopicPartitionKey

java.lang.Object

io.confluent.parallelconsumer.state.ShardKey

io.confluent.parallelconsumer.state.ShardKey.TopicPartitionKey

Enclosing class:

ShardKey

public static final class ShardKey.TopicPartitionKey
extends ShardKey

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.parallelconsumer.state.ShardKey

ShardKey.KeyOrderedKey, ShardKey.TopicPartitionKey

Constructor Summary

Constructors

Constructor	Description
TopicPartitionKey(org.apache.kafka.common.TopicPartition topicPartition)

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
org.apache.kafka.common.TopicPartition	getTopicPartition()
int	hashCode()
String	toString()

Methods inherited from class io.confluent.parallelconsumer.state.ShardKey

of, of, ofKey, ofTopicPartition

Methods inherited from class java.lang.Object

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

Constructor Details

TopicPartitionKey

public TopicPartitionKey(org.apache.kafka.common.TopicPartition topicPartition)

Method Details

getTopicPartition

public org.apache.kafka.common.TopicPartition getTopicPartition()

toString

public String toString()

Overrides:

toString in class ShardKey

equals

public boolean equals(Object o)

Overrides:

equals in class ShardKey

canEqual

protected boolean canEqual(Object other)

Overrides:

canEqual in class ShardKey

hashCode

public int hashCode()

Overrides:

hashCode in class ShardKey