public interface TopicsMetadataSnapshot
MetadataCache
,
whereas in KRaft-mode, it is fetched from the SbcMetadataUpdateEvent.Modifier and Type | Interface and Description |
---|---|
static interface |
TopicsMetadataSnapshot.PartitionSnapshot
Basic information around a partition.
|
static interface |
TopicsMetadataSnapshot.ReplicaInfo
Extra information about the replicas of a given partition.
|
Modifier and Type | Method and Description |
---|---|
Optional<TopicsMetadataSnapshot.ReplicaInfo> |
partitionInfoSnapshot(TopicsMetadataSnapshot.PartitionSnapshot partitionSnapshot)
Fetch extra info about a
TopicsMetadataSnapshot.PartitionSnapshot . |
List<List<TopicsMetadataSnapshot.PartitionSnapshot>> |
partitionsByTopic() |
List<List<TopicsMetadataSnapshot.PartitionSnapshot>> partitionsByTopic()
TopicsMetadataSnapshot.PartitionSnapshot
s for a given topic.
To be efficient in terms of time complexity, it is suggested implementations compute this collection just once and expose a view of it.Optional<TopicsMetadataSnapshot.ReplicaInfo> partitionInfoSnapshot(TopicsMetadataSnapshot.PartitionSnapshot partitionSnapshot)
TopicsMetadataSnapshot.PartitionSnapshot
.