public class TopicsImageMetadataSnapshot extends Object implements kafka.common.TopicsMetadataSnapshot
TopicsMetadataSnapshot
that leverages the KRaft-provided TopicsImage
metadataModifier and Type | Class and Description |
---|---|
class |
TopicsImageMetadataSnapshot.TopicImagePartitionSnapshot |
class |
TopicsImageMetadataSnapshot.TopicImageReplicaInfo |
Constructor and Description |
---|
TopicsImageMetadataSnapshot(org.apache.kafka.image.TopicsImage topicsImage) |
Modifier and Type | Method and Description |
---|---|
Optional<kafka.common.TopicsMetadataSnapshot.ReplicaInfo> |
partitionInfoSnapshot(kafka.common.TopicsMetadataSnapshot.PartitionSnapshot partitionSnapshot) |
List<List<kafka.common.TopicsMetadataSnapshot.PartitionSnapshot>> |
partitionsByTopic() |
public TopicsImageMetadataSnapshot(org.apache.kafka.image.TopicsImage topicsImage)
public List<List<kafka.common.TopicsMetadataSnapshot.PartitionSnapshot>> partitionsByTopic()
partitionsByTopic
in interface kafka.common.TopicsMetadataSnapshot
public Optional<kafka.common.TopicsMetadataSnapshot.ReplicaInfo> partitionInfoSnapshot(kafka.common.TopicsMetadataSnapshot.PartitionSnapshot partitionSnapshot)
partitionInfoSnapshot
in interface kafka.common.TopicsMetadataSnapshot