Class KafkaTopicCatalogTargetProcessor


public class KafkaTopicCatalogTargetProcessor extends CatalogTargetProcessorBase
KafkaTopicIntegrationConnector catalogues active topics in a kafka broker.
  • Constructor Details

  • Method Details

    • refresh

      public void refresh() throws ConnectorCheckedException
      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
      Throws:
      ConnectorCheckedException - there is a problem with the connector. It is not able to refresh the metadata.
    • refreshEventBroker

      public void refreshEventBroker(String targetRootURL, String templateGUID, String templateQualifiedName) throws ConnectorCheckedException
      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. This method performs two sweeps. It first retrieves the topics from the event broker (Kafka) and validates that are in the catalog - adding or updating them if necessary. The second sweep is to ensure that all the topics catalogued actually exist in the event broker.
      Parameters:
      targetRootURL - URL to the Kafka Broker
      templateGUID - optional template to use when creating new topics
      templateQualifiedName - qualifiedName for template - only set if templateGUID is set
      Throws:
      ConnectorCheckedException - there is a problem with the connector. It is not able to refresh the metadata.