Package io.confluent.parallelconsumer.state

Class ShardKey

java.lang.Object

io.confluent.parallelconsumer.state.ShardKey

Direct Known Subclasses:

ShardKey.KeyOrderedKey, ShardKey.TopicPartitionKey

public class ShardKey
extends Object

Simple value class for processing ShardKeys to make the various key systems type safe and extendable.

Author:

Antony Stubbs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ShardKey.KeyOrderedKey
static final class	ShardKey.TopicPartitionKey

Constructor Summary

Constructors

Constructor	Description
ShardKey()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
int	hashCode()
static ShardKey	of(WorkContainer<?,?> wc, ParallelConsumerOptions.ProcessingOrder ordering)
static ShardKey	of(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec, ParallelConsumerOptions.ProcessingOrder ordering)
static ShardKey.KeyOrderedKey	ofKey(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec)
static ShardKey	ofTopicPartition(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ShardKey

public ShardKey()

Method Details

of

public static ShardKey of(WorkContainer<?,?> wc,
 ParallelConsumerOptions.ProcessingOrder ordering)

of

public static ShardKey of(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec,
 ParallelConsumerOptions.ProcessingOrder ordering)

ofKey

public static ShardKey.KeyOrderedKey ofKey(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec)

ofTopicPartition

public static ShardKey ofTopicPartition(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object