Class KafkaOpenMetadataTopicConnector

All Implemented Interfaces:
Runnable, AuditLoggingComponent, SecureConnectorExtension, OpenMetadataTopic

public class KafkaOpenMetadataTopicConnector extends OpenMetadataTopicConnector
KafkaOMRSTopicConnector provides a concrete implementation of the OMRSTopicConnector that uses native Apache Kafka as the event/messaging infrastructure.
  • Constructor Details

    • KafkaOpenMetadataTopicConnector

      public KafkaOpenMetadataTopicConnector()
      Constructor sets up the default properties for the producer and consumer. Any properties passed through the connection's additional properties will override these values. For most environments, The caller only needs to provide details of the bootstrap servers as the default properties will support the open metadata workloads.
  • Method Details