Uses of Class
io.confluent.parallelconsumer.state.ShardKey

Packages that use ShardKey

Package	Description
io.confluent.parallelconsumer.state

Uses of ShardKey in io.confluent.parallelconsumer.state

Subclasses of ShardKey in io.confluent.parallelconsumer.state

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

Methods in io.confluent.parallelconsumer.state that return ShardKey

Modifier and Type	Method	Description
static ShardKey	ShardKey.of(WorkContainer<?,?> wc, ParallelConsumerOptions.ProcessingOrder ordering)
static ShardKey	ShardKey.of(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec, ParallelConsumerOptions.ProcessingOrder ordering)
static ShardKey	ShardKey.ofTopicPartition(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> rec)

Constructors in io.confluent.parallelconsumer.state with parameters of type ShardKey

Modifier	Constructor	Description
	ProcessingShard(ShardKey key, ParallelConsumerOptions<?,?> options, PartitionStateManager<K,V> pm)