Package org.odpi.openmetadata.adapters.eventbus.topic.kafka
package org.odpi.openmetadata.adapters.eventbus.topic.kafka
-
ClassDescriptionWrapper class for kafka configuration that allows us to get at its properties.
IncomingEvent
that came from KafkaKafkaOpenMetadataEventConsumer is used to process events from kafka topic and is part of native Apache Kafka event/messaging infrastructure.Configuration for theKafkaOpenMetadataEventConsumerConfiguration
Configurable properties for the KafkaOpenMetadataEventConsumerKafkaOpenMetadataEventProducer manages the sending of events on Apache Kafka.KafkaOMRSTopicConnector provides a concrete implementation of the OMRSTopicConnector that uses native Apache Kafka as the event/messaging infrastructure.The KafkaOpenMetadataTopicConnectorAuditCode is used to define the message content for the Audit Log.The KafkaOpenMetadataTopicConnectorErrorCode is used to define first failure data capture (FFDC) for errors that occur when working with the Apache Kafka connector.KafkaOpenMetadataTopicProvider provides implementation of the connector provider for the KafkaOpenMetadataTopicConnector.