[
https://issues.apache.org/jira/browse/ATLAS-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325702#comment-16325702
]
Mandy Chessell commented on ATLAS-2109:
---------------------------------------
Hello Cassio - this is exactly right up to the point that the EntityDetail
object is created from the call to the IGC connector.
The EntityDetail object should then be passed to the repository event processor
object that is passed to the repository event mapper on the
setRepositoryEventProcessor(OMRSRepositoryEventProcessor
repositoryEventProcessor)
method. The repository event processor implements the
org.apache.atlas.omrs.eventmanagement.OMRSRepositoryEventProcessor interface.
This includes a method called:
void processNewEntityEvent(String sourceName,
String originatorMetadataCollectionId,
String originatorServerName,
String originatorServerType,
String originatorOrganizationName,
EntityDetail entity);
The other parameters are provided to the event mapper on the initialize() call.
When the processNewEntityEvent() method is called, the repository event
processor will look up the configuration rules defined for how events from the
local repository (IGC in this case) should be processed. It then routes the
supplied EntityDetail to the right OMRSEventPublisher instances running in the
server which will create the event payload and push to Kafka.
The IGC connector/event mapper does not need to locate the active version of
the event payload, construct the OMRS Event payload, nor locate the correct
OMRS Topic Connector to pass the event to it. The OMRS handles all of that.
> Create basic IGC OMRS Connector for existing releases
> -----------------------------------------------------
>
> Key: ATLAS-2109
> URL: https://issues.apache.org/jira/browse/ATLAS-2109
> Project: Atlas
> Issue Type: Sub-task
> Components: atlas-core
> Reporter: Mandy Chessell
>
> This is the first version of the IGC OMRS Connector that works with existing
> IGC servers.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
