search

neo4j-contrib / neo4j-streams

Neo4j Kafka Connector
https://neo4j.com/docs/kafka
Apache License 2.0
173 stars 71 forks source link

Option to parse the key and the header of the message from Cypher #540

Open alfredorubin96 opened 2 years ago

alfredorubin96 commented 2 years ago

Feature description (Mandatory)

Inserting an option that can send the message as a dictionary containing header, key and value instead of only the value of the message can help us manage complex logics directly inside neo4j and to work with other Kafka Connectors (EX: Debezium MongoDB source connector sends some params inside the key, for example on the deletion of a document the _oid field of the deleted doc is contained only inside the key of a tombstone record). The option should be disabled by default and activated only if the user wants it.

Thanks in advance for your help

ali-ince commented 1 year ago

Hi @alfredorubin96, would you please provide a concrete example for us to evaluate this feature request?