public class ZkMetadataEventProvider extends Object implements MetadataEventProvider<String>
Constructor and Description |
---|
ZkMetadataEventProvider(LocalStore localStore,
String logicalCluster) |
Modifier and Type | Method and Description |
---|---|
Iterable<String> |
clusterLinkIterable()
Get all cluster link identifiers of a logical cluster that this provider provides.
|
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
getClusterLinkMetadata(String clusterLink)
Given a cluster link identifier, return the corresponding
MetadataEvent for the
cluster link |
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
getTopicMetadata(String topic)
Given a topic identifier, return the corresponding
MetadataEvent for this topic |
Iterable<String> |
topicIterable()
Get all topic identifiers of a logical cluster that this provider provides.
|
public ZkMetadataEventProvider(LocalStore localStore, String logicalCluster)
public Iterable<String> topicIterable()
MetadataEventProvider
topicIterable
in interface MetadataEventProvider<String>
public Iterable<String> clusterLinkIterable()
MetadataEventProvider
clusterLinkIterable
in interface MetadataEventProvider<String>
public io.confluent.protobuf.events.catalog.v1.MetadataEvent getTopicMetadata(String topic)
MetadataEventProvider
MetadataEvent
for this topicgetTopicMetadata
in interface MetadataEventProvider<String>
topic
- the identifierpublic io.confluent.protobuf.events.catalog.v1.MetadataEvent getClusterLinkMetadata(String clusterLink)
MetadataEventProvider
MetadataEvent
for the
cluster linkgetClusterLinkMetadata
in interface MetadataEventProvider<String>
clusterLink
- the identifier