Skip to content
Sample

This component is supplied as a sample. You may use it "as is" or modify it to your own requirements.

Kafka Topics Audit Integration Connector

Connector details

Overview

The kafka topics audit integration connector monitors an Apache Kafka server and validates that a KafkaTopic asset is catalogued for each topic that is known to the server.

Figure 1

Figure 1: Operation of the kafka topics audit integration connector

Configuration

This connector uses the Topic Integrator OMIS running in the Integration Daemon.

This is its connection definition to use on the administration commands that configure the Topic Integrator OMIS.

Connection configuration

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
{
   "connection" : 
                { 
                    "class" : "Connection",
                    "qualifiedName" : "TopicMonitorConnection",
                    "connectorType" : 
                    {
                        "class" : "ConnectorType",
                        "connectorProviderClassName" : "org.odpi.openmetadata.devprojects.connectors.integration.kafka.KafkaTopicsAuditIntegrationProvider"
                    },
                    "endpoint" :
                    {
                        "class" : "Endpoint",
                        "address" : "{{serverURL}}"
                    }
                }
}
  • Replace {{serverURL]} with the network address of Kafka's bootstrap server (for example, localhost:9092).

Raise an issue or comment below