co.cask.cdap.data2.metadata.publisher

Class KafkaMetadataChangePublisher

java.lang.Object

co.cask.cdap.data2.metadata.publisher.KafkaMetadataChangePublisher

All Implemented Interfaces:

MetadataChangePublisher

public class KafkaMetadataChangePublisher
extends Object
implements MetadataChangePublisher

A MetadataChangePublisher that publishes metadata changes to an Apache Kafka topic determined by the configuration parameter metadata.updates.kafka.topic. External systems can get notifications of metadata changes by subscribing to this topic.

Method Summary

Methods

Modifier and Type	Method and Description
void	publish(MetadataChangeRecord changeRecord) Publishes a MetadataChangeRecord to a messaging system.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

publish

public void publish(MetadataChangeRecord changeRecord)

Description copied from interface: MetadataChangePublisher

Publishes a MetadataChangeRecord to a messaging system.

Specified by:

publish in interface MetadataChangePublisher

Parameters:

changeRecord - the MetadataChangeRecord to publish