...
Currently, transaction event generated as part of neo4j transaction gets pushed into
learning.graph.eventkafka topic by logstash.We can write a Flink job at the consumption layer which will
Read
learning.graph.eventKafka topic of consumption layer.Search the object from the consumption layer and find the origin id
if the origin id exists in the sourcing database, the metric specific data will be updated in the sourcing database object.
Conclusion:
<TODO>