public static interface ClusterMetadataTopicsSnapshot.PartitionInfoSupplier
MetadataCache.getPartitionInfo(String, int)
Modifier and Type | Method and Description |
---|---|
scala.Option<org.apache.kafka.common.message.UpdateMetadataRequestData.UpdateMetadataPartitionState> |
getPartitionInfo(String topic,
int partitionId) |
scala.Option<org.apache.kafka.common.message.UpdateMetadataRequestData.UpdateMetadataPartitionState> getPartitionInfo(String topic, int partitionId)