https://github.com/neo4j-contrib/neo4j-streams/blob/4.1/kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/source/Neo4jSourceConnector.kt
(из всего репо нужен только этот модуль)
вот тут модуль расширения для бд Neo4j он получает CDC-события из Neo4j и отправляет их в kafka
нужно отправлять события не в kafka, а в azure event hub (урезанная kafka) или azure service bus (amqp, аналог rabbitmq)
https://github.com/ikwattro/neo4j-transaction-event-listener-extension
вот пример аналогичного обработчика событий (на java)

не нужно разбираться в нюансах kafka, event hub и прочего - у меня есть экспертиза в этом вопросе, но в другом стеке (.net/c#)
в чем нет экспертизы - это kotlin и java

нужно
- либо сделать модуль самостоятельно
- либо посидеть со мной и сделать его вместе (не думаю что mvp займет больше чем несколько часов)