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

Class KafkaTopicSourceCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

org.odpi.openmetadata.frameworks.opengovernance.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

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

connectorToTarget, integrationContext

Constructor Summary

Constructors

Constructor	Description
KafkaTopicSourceCatalogTargetProcessor(CatalogTarget template, CatalogTargetContext catalogTargetContext, 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, getConnectorToTarget, getIntegrationContext, hashCode, toString

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

getCatalogTargetElement, getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplates, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplates

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

getExtendedProperties, getTypeName, setExtendedProperties, setTypeName

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

getEffectiveFrom, getEffectiveTo, setEffectiveFrom, setEffectiveTo

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaTopicSourceCatalogTargetProcessor

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

Copy/clone constructor

Parameters:

template - object to copy

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

listener - listener

Throws:

ConnectorCheckedException - problem connecting to topic

UserNotAuthorizedException - the connector was disconnected before/during start

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