Package org.odpi.openmetadata.adapters.connectors.integration.kafkaaudit

Class KafkaTopicSourceCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTargetProperties

org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTarget

org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

org.odpi.openmetadata.adapters.connectors.integration.kafkaaudit.KafkaTopicSourceCatalogTargetProcessor

public class KafkaTopicSourceCatalogTargetProcessor
extends CatalogTargetProcessorBase

Listens for events from Apache Kafka that contain audit log events.

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

auditLog, connectorName, propertyHelper

Constructor Summary

Constructors

Constructor	Description
KafkaTopicSourceCatalogTargetProcessor(CatalogTarget template, Connector connectorToTarget, String connectorName, AuditLog auditLog, OpenMetadataTopicListener listener)	Copy/clone constructor

Method Summary

Modifier and Type	Method	Description
void	refresh()	Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

getDateConfigurationProperty, getStringConfigurationProperty

Methods inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

equals, getCatalogTargetConnector, hashCode, setCatalogTargetConnector, toString

Methods inherited from class org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTarget

getCatalogTargetElement, getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplateProperties, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplateProperties

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

KafkaTopicSourceCatalogTargetProcessor

public KafkaTopicSourceCatalogTargetProcessor(CatalogTarget template,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog,
 OpenMetadataTopicListener listener)
                                       throws ConnectorCheckedException

Copy/clone constructor

Parameters:

template - object to copy

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

listener - listener

Throws:

ConnectorCheckedException - problem connecting to topic

Method Details

refresh

public void refresh()

Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories. Refresh is called when the integration connector first starts and then at intervals defined in the connector's configuration as well as any external REST API calls to explicitly refresh the connector.

Specified by:

refresh in class CatalogTargetProcessorBase