Egeria has a growing collection of connectors to third party technologies. These connectors help to accelerate the rollout of your open metadata ecosystem since they can be used to automate the extraction and distribution of metadata to the third party technologies.
A connector is a client to a third party technology. It supports a standard API that Egeria calls, and it then translates these calls into requests to the third party technology. Some connectors are also able to listen for notifications from the third party technology. When a notification is received, the connector converts its content into a call to Egeria to distribute the information to the open metadata ecosystem.
Connectors enable Egeria to operate in many environments and with many types of third party technologies, just by managing the configuration of the OMAG servers. The Connector Catalog list the connector implementations supplied by the Egeria community. There are three broad categories of connectors and the connector catalog is organized accordingly:
-
Connectors that support the exchange and maintenance of metadata with third party technology. This includes the resource connectors, survey action connectors, integration connectors and adapter repository connectors. These connectors are organized by the type of third part technology type work with.
-
Connectors that support the governance of open metadata. This includes the context event services and governance action services. These connectors are organized by function.
-
Connectors that support the integration of Egeria’s runtimes into the IT infrastructure where it is running. This includes the native repository connectors, event bus connectors, cohort registry stores, configuration stores, audit log destination connectors, open metadata archive stores, REST client connectors and the cohort member remote repository connectors. These connectors are organized by connector type.
The connectors that support the exchange and maintenance of metadata help to accelerate the rollout of your open metadata ecosystem, since they can be used to automate the extraction and distribution of metadata to the third party technologies.
- Secrets Store connectors manage the retrieval of secrets (passwords, certificates, ...) from secured locations at runtime.
- File connectors work with different types of files.
- JDBC Database connectors make use of the JDBC standards to work with different types of relational databases.
- Apache Kafka connectors work with the topics and/or events passing through the Apache Kafka event broker.
- Apache Atlas connectors work with an Apache Atlas server.
- Strimzi connector works with the cloud-based Apache Kafka deployment called Strimzi.
- Open API Specification connectors extract metadata about APIs through the Open API interfaces provided through the Swagger API.
- Open Lineage Event connectors works with the open lineage event standard.
Secrets stores externalize secrets such as passwords, tokens and certificates so they do not need to be stored in either the configuration document or open metadata repositories.
- The Environment Variables Secret Store connector retrieves secret values from environment variables.
- The YAML File Secret Store connector retrieves secret values from environment variables.
Files provide storage for many types of data. They are organizes into folders (also known as directories on some operating systems). Some connectors work with any type of file. Other connectors are able to understand the content of specific types of file formats and so these connectors are organized by file type.
- The Basic File Resource Connector provides support to read and write to a file using the Java File object.
- The Move/Copy File Provisioning Governance Action Service moves or copies files from one location to another and maintains the lineage of the action.
- The Basic Folder Resource Connector is for accessing the files within a folder (directory).
- The Data Files Monitor Integration Connector maintains a
DataFile
asset for each file in the directory (or any subdirectory). When a new file is created, a new DataFile asset is created. If a file is modified, the lastModified property of the corresponding DataFile asset is updated. When a file is deleted, its corresponding DataFile asset is also deleted (or archived if it is still needed for lineage). - The Generic Folder Watchdog Governance Action Service listens for changing
DataFile
assets linked to a specifiedFileFolder
element and initiates governance actions when specific events occur. This may be for files directly linked to the folder or located in sub-folders.
- The Data Folder Resource Connector is for accessing data that is stored as a number of files within a folder (directory).
- The Data folder Monitor Integration Connector maintains a
DataFolder
asset for the directory. The files and directories underneath it are assumed to be elements/records in the DataFolder asset and so each time there is a change to the files and directories under the monitored directory, it results in an update to the lastModified property of the corresponding DataFolder asset.
- The CSV File Resource Connector is able to retrieve data from a Comma Separated Values (CSV) file where the contents are stored in logical columns with a special character delimiter between the columns.
- The File-based Open Metadata Archive Store Connector :material-github:{ target=gh } stores an open metadata archive as a plain text JSON file.
- The JDBC Resource Connector is for accessing a database via the JDBC DataSource interface.
- The JDBC Integration Connector automatically maintains the open metadata instances on a database server via JDBC. This includes the database schemas, tables, columns, primary keys and foreign keys.
---8<-- "snippets/systems/unity-catalog-intro.md"
The Unity Catalog connectors provide a suite of function that integrates a Unity Catalog server into the open metadata ecosystem.
- The Unity Catalog Resource Connector is a digital resource connector that acts as a Java client to the Unity Catalog Server REST API. It is used by the other Unity Catalog connectors.
- The Unity Catalog Server Synchronizer is an integration connector that exchanges details about the catalogs defined for a Unity Catalog Server.
- The Unity Catalog Inside Catalog Synchronizer is an integration connector that exchanges details about the resources (schemas, tables, volumes and functions) defined within a Catalog found in a Unity Catalog Server.
- The Unity Catalog Server Survey Service is a Survey Action Service that surveys the resources defined in a Unity Catalog Server.
- The Unity Catalog Inside Catalog Survey Service is a Survey Action Service that surveys the resources defined in a Catalog inside a Unity Catalog Server.
- The Unity Catalog Inside Schema Survey Service is a Survey Action Service that surveys the resources defined in a Schema inside a Unity Catalog Server.
- The Kafka Open Metadata Topic Connector implements a resource connector for a topic that exchanges Java Objects as JSON payloads across an Apache Kafka event bus. It is configured in the Egeria OMAG Servers through the Event Bus Configuration. This the connector that is used by default in the Egeria runtimes to exchange events (notifications between the OMAG Servers).
- The Kafka Monitor Topic integration connector automatically maintains the open metadata instances for the topics hosted on an Apache Kafka server :material-dock-window:{ target=kafka }.
- The Kafka Audit Topic integration connector validates that topics that are active in an Apache Kafka server :material-dock-window:{ target=kafka } are also catalogued in open metadata. Creates an audit log record for each topic that is not catalogued.
- The Sample Lineage Integration Connector is a sample connector to listen for lineage events (not in an open lineage format) and catalog the associated assets, processes, schema and lineage. |
---8<-- "snippets/systems/apache-atlas-intro.md"
The Apache Atlas connectors provide a suite of function that integrates an Apache Atlas server into the open metadata ecosystem.
- Apache Atlas REST Connector is a digital resource connector that acts as a Java client to the Apache Atlas Server REST API. It is used by the other Apache Atlas connectors.
- Apache Atlas Survey Action Service reviews the types and instances stored in an Apache Atlas Server and creates a survey report. This connector helps to provide insight into the content of the Apache Atlas server to determine if it contains valuable metadata that should be integrated into the open metadata ecosystem. This connector can also be configured to create a graph schema for the server that describes is supported types and how they link together.
- Apache Atlas Integration Connector automatically catalogues the content of an Apache Atlas Server into the open metadata ecosystem. It may also be configured to push selected open metadata into the Apache Atlas Server, such as glossary terms, tags and classifications.
- Strimzi Monitor topic integration connector automatically maintains the open metadata instances for the topics hosted in Strimzi :material-dock-window:{ target=strimzi }.
The Open API Monitor integration connector automatically maintains the open metadata instances for the APIs extracted from the Open API Specification extracted from an application.
The open lineage connectors work with the Open Lineage standard
- Open Lineage Event Receiver integration connector receives open lineage events from an event topic and publish them to lineage integration connectors with listeners registered in the same instance of the Lineage Integrator OMIS.
- Governance Action to Open Lineage integration connector listens for governance actions executing in the open metadata ecosystem, generate open lineage events for them and publish them to the integration connectors running in the same instance of Lineage Integrator OMIS that are listening for OpenLineage events.
- API-based Open Lineage Log Store integration connector calls an OpenLineage compliant API to store the open lineage events that are passed to it through the OpenLineage listener that is registered with the Lineage Integrator OMIS.
- File-based Open Lineage Log Store integration connector stores the open lineage events that are passed to it through the OpenLineage listener that is registered with the Lineage Integrator OMIS. Each OpenLineage event is stored in its own file in JSON format. These files are organized according to the namespace and job name in the event.
- Open Lineage Cataloguer integration connector registers an Open Lineage listener with the Lineage Integrator OMIS and to catalog any processes that are not already known to the open metadata ecosystem.
- The Generic Element Watchdog Governance Action Service listens for changing metadata elements and initiates governance action processes when certain events occur.
- The Origin Seeker Governance Action Service walks backwards through the lineage relationships to discover the origin of the data asset.
- The Zone Publisher Governance Action Service updates the zone membership on the target action assets.
Runtime connectors enable Egeria's OMAG Server Platform and its hosted OMAG Servers to operate in many environments by providing plug-in points for the runtime services it needs to operate. Most of the runtime connectors relate to persistent storage, or connections to distributed services. The connectors are organized by type to allow you to choose the options available from the Egeria community.
Type | Description |
---|---|
Repository and Event Mapper connectors | Integrate metadata repositories into the open metadata ecosystem so that they can interact with one or more open metadata repository cohorts. |
Platform Metadata Security Connectors | manage authorization requests for the OMAG Server Platform's services. |
Server Metadata Security Connectors | manage authorization requests for the OMAG Server's services. |
Configuration Document Store Connectors | manage the persistence and retrieval of configuration documents. |
Cohort Registry Store Connectors | store the open metadata repository cohort membership details in the cohort registry store. |
Open Metadata Archive Store Connectors | read and write open metadata archives. |
Audit Log Destination Connectors | support different destinations for audit log records. |
REST Client Connectors | issue REST API calls to Egeria's deployed platforms and third party technologies. |
Cohort Member Client Connector | supports repository service called to remote cohort members. |
Open Metadata Topic Connectors | send and receive events. |
---8<-- "snippets/connectors/repository-connector-intro.md"
The table below lists the repository connectors supporting the native open metadata repositories.
Native Repository Connector | Description |
---|---|
PostgreSQL OMRS Repository Connector | provides a native repository for a metadata server using PostgreSQL :material-dock-window:{ target=postgres } as the backend. |
XTDB OMRS Repository Connector | provides a native repository for a metadata server that supports historical queries, using XTDB :material-dock-window:{ target=xtdb } as the persistent store. |
In-memory OMRS Repository Connector | provides a simple native repository implementation that "stores" metadata in HashMaps within the JVM; it is used for testing, or for environments where metadata maintained in other repositories needs to be cached locally for performance/scalability reasons. |
Read-only OMRS Repository Connector | provides a native repository implementation that does not support the interfaces for create, update, delete; however, it does support the search interfaces and is able to cache metadata -- this means it can be loaded with open metadata archives to provide standard metadata definitions. |
JanusGraph OMRS Repository Connector | provides a native repository for a metadata server using JanusGraph :material-dock-window:{ target=janus } as the backend. |
The table below lists the repository connectors that act as an adapter for third party metadata repositories.
Adapter Repository Connectors | Description |
---|---|
IBM Information Governance Catalog (IGC) OMRS Repository Connector :material-github:{ target=gh } | implements read-only connectivity to the metadata repository within the IBM InfoSphere Information Server :material-dock-window:{ target=ibm } suite |
SAS Viya OMRS Repository Connector :material-github:{ target=gh } | implements metadata exchange to the metadata repository within the SAS Viya Platform :material-dock-window:{ target=sas } |
Sample Repository proxy (adapter) using polling to access files :material-github:{ target=gh } | implements metadata exchange to a file system using a polling pattern and an embedded OMRS repository. |
HMS Repository proxy (adapter) using polling to access HMS Tables :material-github:{ target=gh } | implements metadata exchange to a Hive metastore using a polling pattern and an embedded OMRS repository. |
??? education "Further information relating to Repository and Event Mapper connectors"
- [Configuring a native repository connector](/guides/admin/servers/by-server-type/configuring-a-metadata-access-store/#configure-the-native-repository-connector) to understand how to set up a repository connector in a [Metadata Access Store](/concepts/metadata-access-store).
- [Configuring an adapter repository connector](/guides/admin/servers/by-server-type/configuring-a-repository-proxy/#configure-the-connectors-to-the-third-party-metadata-repository) to understand how to set up a repository connector in a [Repository Proxy](/concepts/repository-proxy).
- [Writing repository and event mapper connectors](/guides/developer/repository-connectors/overview) for more information on writing new repository and event mapper connectors.
---8<-- "snippets/connectors/platform-metadata-security-connector-intro.md"
There is one implementation of the platform metadata security connector provided by Egeria. It is a sample that encodes information from the Coco Pharmaceutical scenarios.
??? education "Further information relating to Platform Metadata Security Connectors"
- [Configuring a Platform Metadata Security Connector](/guides/admin/configuring-the-omag-server-platform/#platform-security) in the [OMAG Server Platform](/concepts/omag-server-platform)
- [Metadata Security](/features/metadata-security/overview) to understand the platform metadata security connector in the context of all of the security features.
- [Writing a Platform Metadata Security Connector](/guides/developer/runtime-connectors/platform-metadata-security-connector).
---8<-- "snippets/connectors/server-metadata-security-connector-intro.md"
There is one implementation of the server metadata security connector provided by Egeria. It is a sample that encodes information from the Coco Pharmaceuticals scenarios.
??? education "Further information relating to Server Metadata Security Connectors"
- [Configuring a Server Metadata Security Connector](/guides/admin/configuring-the-omag-server-platform/#platform-security) in the [OMAG Server Platform](/concepts/omag-server-platform)
- [Metadata Security](/features/metadata-security/overview) to understand the server metadata security connector in the context of all of the security features.
- [Writing a Server Metadata Security Connector](/guides/developer/runtime-connectors/server-metadata-security-connector).
---8<-- "snippets/connectors/configuration-document-store-connector-intro.md"
There are two implementations of the configuration document store connector provided by Egeria: one for an encrypted store (default) and the other for a plain text store.
-
Encrypted File Configuration Store Connector :material-github:{ target=gh } stores each configuration document as an encrypted JSON file.
-
File Configuration Store :material-github:{ target=gh } stores each configuration document as a clear text JSON file.
??? education "Further information relating to Configuration Document Store Connectors"
- [Configuring a Configuration Document Store Connector](/guides/admin/configuring-the-omag-server-platform/#configuration-store) in the [OMAG Server Platform](/concepts/omag-server-platform)
- [Writing a Configuration Document Store Connector](/guides/developer/runtime-connectors/configuration-document-store-connector).
---8<-- "snippets/connectors/cohort-registry-store-connector-intro.md"
Egeria provides a single implementation of a cohort registry store connector:
- Cohort Registry File Store Connector :material-github:{ target=gh } provides the means to store the cohort registry membership details as a JSON file.
??? education "Further information relating to Cohort Registry Store Connectors"
- [Configuring a Cohort Registry Store Connector](/guides/admin/servers/by-section/repository-services-section/#registering-the-server-with-a-cohort) in the [Cohort Member](/concepts/cohort-member) server.
- [Cohort Operations](/features/cohort-operations/overview) to understand the way the cohort is formed.
- [Writing a Cohort Registry Store Connector](/guides/developer/runtime-connectors/cohort-registry-store-connector).
---8<-- "snippets/connectors/open-metadata-archive-store-connector-intro.md"
Egeria provides two implementations of the open metadata archive store connector:
-
File-based Open Metadata Archive Store Connector :material-github:{ target=gh } stores an open metadata archive as a plain text JSON file.
-
Directory-based Open Metadata Archive File Store Connector :material-github:{ target=gh } stores an open metadata archive in a directory structure where each type definition and metadata instance is stored in JSON format in its own file.
??? education "Further information relating to Open Metadata Archive Store Connectors"
- [Metadata Archiving](/features/metadata-archiving/overview) to understand the different mechanisms that use open metadata archives.
- [Open Metadata Archives](/concepts/open-metadata-archive) to understand structure of an open metadata archive.
- [Writing a Open Metadata Archive Store Connector](/guides/developer/runtime-connectors/open-metadata-archive-store-connector).
- [Loading an Open Metadata Archive at server statup](/guides/admin/servers/by-section/repository-services-section/#configuring-the-open-metadata-archives-to-load-on-server-startup)
- [Loading an Open Metadata Archive in a running server](/guides/operations/adding-archive-to-running-server)
---8<-- "snippets/connectors/audit-log-destination-connector-intro.md"
Below are the connector implementations provided by Egeria
-
Console Audit Log Connector :material-github:{ target=gh } writes selected parts of each audit log record to stdout.
-
slf4j Audit Log Connector :material-github:{ target=gh } writes full log records to the slf4j ecosystem.
-
File Audit Log Connector :material-github:{ target=gh } creates log records as JSON files in a shared directory.
-
Event Topic Audit Log Connector :material-github:{ target=gh } sends each log record as an event on the supplied event topic.
??? education "Further information relating to Audit Log Destination Connectors"
- [Configuring a Audit Log Destination Connector](/concepts/audit-log/#configure-the-audit-log) in the [Cohort Member](/concepts/cohort-member) server
- [Audit Log Framework (ALF)](/frameworks/alf/overview) to understand the framework behind the audit log.
- [Writing a Audit Log Destination Connector](/guides/developer/runtime-connectors/audit-log-destination-connector).
---8<-- "snippets/connectors/rest-client-connector-intro.md"
Egeria provides a single implementation for Spring.
- Spring REST Client Connector :material-github:{ target=gh } uses the Spring RESTClient to issue REST API calls.
This is embedded in Egeria's Java clients. See
- Egeria's Platform API clients.
- Egeria's OMAS clients.
---8<-- "snippets/connectors/cohort-member-client-connector-intro.md"
Egeria's Open Metadata Repository Services (OMRS) provides a default REST API implementation and a corresponding client:
- REST Cohort Client Connector :material-github:{ target=gh } supports remote calls to the OMRS REST API.
The connection for this connector is configured in the LocalRepositoryRemoteConnection
property of the
cohort member's Local Repository Configuration.
--8<-- "snippets/abbr.md"