public class TierTopicPartitioner
extends java.lang.Object
Constructor and Description |
---|
TierTopicPartitioner(int numPartitions) |
Modifier and Type | Method and Description |
---|---|
int |
partitionId(org.apache.kafka.common.TopicPartition topicPartition)
Determine the Tier Topic partitionId that should contain metadata for a given tiered
TopicPartition
|