public interface InitializedTierTopic
Modifier and Type | Method and Description |
---|---|
OptionalInt |
numPartitions() |
String |
topicName() |
org.apache.kafka.common.TopicPartition |
toTierTopicPartition(TopicIdPartition tieredPartition) |
Set<org.apache.kafka.common.TopicPartition> |
toTierTopicPartitions(Collection<TopicIdPartition> tieredPartitions) |
Set<org.apache.kafka.common.TopicPartition> toTierTopicPartitions(Collection<TopicIdPartition> tieredPartitions)
org.apache.kafka.common.TopicPartition toTierTopicPartition(TopicIdPartition tieredPartition)
String topicName()
OptionalInt numPartitions()