public class KRaftMetadataEventProvider extends Object implements MetadataEventProvider<org.apache.kafka.common.Uuid>
Constructor and Description |
---|
KRaftMetadataEventProvider(KRaftMetadataCollector collector,
Set<org.apache.kafka.common.Uuid> topics,
Set<org.apache.kafka.common.Uuid> linkIds,
org.apache.kafka.image.MetadataImage metadataImage) |
Modifier and Type | Method and Description |
---|---|
Iterable<org.apache.kafka.common.Uuid> |
clusterLinkIterable()
Get all cluster link identifiers of a logical cluster that this provider provides.
|
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
getClusterLinkMetadata(org.apache.kafka.common.Uuid clusterLink)
Given a cluster link identifier, return the corresponding
MetadataEvent for the
cluster link |
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
getTopicMetadata(org.apache.kafka.common.Uuid topic)
Given a topic identifier, return the corresponding
MetadataEvent for this topic |
Iterable<org.apache.kafka.common.Uuid> |
topicIterable()
Get all topic identifiers of a logical cluster that this provider provides.
|
public KRaftMetadataEventProvider(KRaftMetadataCollector collector, Set<org.apache.kafka.common.Uuid> topics, Set<org.apache.kafka.common.Uuid> linkIds, org.apache.kafka.image.MetadataImage metadataImage)
public Iterable<org.apache.kafka.common.Uuid> topicIterable()
MetadataEventProvider
topicIterable
in interface MetadataEventProvider<org.apache.kafka.common.Uuid>
public Iterable<org.apache.kafka.common.Uuid> clusterLinkIterable()
MetadataEventProvider
clusterLinkIterable
in interface MetadataEventProvider<org.apache.kafka.common.Uuid>
public io.confluent.protobuf.events.catalog.v1.MetadataEvent getTopicMetadata(org.apache.kafka.common.Uuid topic)
MetadataEventProvider
MetadataEvent
for this topicgetTopicMetadata
in interface MetadataEventProvider<org.apache.kafka.common.Uuid>
topic
- the identifierpublic io.confluent.protobuf.events.catalog.v1.MetadataEvent getClusterLinkMetadata(org.apache.kafka.common.Uuid clusterLink)
MetadataEventProvider
MetadataEvent
for the
cluster linkgetClusterLinkMetadata
in interface MetadataEventProvider<org.apache.kafka.common.Uuid>
clusterLink
- the identifier