3.5.4

Hello Neo4j Community!
We're very happy to present the new 3.5.4 release of the Neo4j Kafka integrations, that is the result of great community feedback!

• We improved the management of the DLQ. Please look at the documentation

• We introduced the support for the transient errors into the Kafka Connect Plugin

• With #211 we introduced the AVRO support to the Neo4j Sink Plugin, the streams.consume procedure manages it as well! Please look at the Supported Kafka deserializers

• With #188 we introduced the support for a new file interexchange format, we called it CUD File Format and is a JSON file that represents Graph Entities (Nodes/Relationships) and how to mange them in term of Create/Update/Delete operations. i.e.:

{
  "op": "merge",
  "properties": {
    "foo": "value",
    "key": 1
  },
  "ids": {"key": 1, "otherKey":  "foo"},
  "labels": ["Foo","Bar"],
  "type": "node",
  "detach": true
}

will be transformed into the follwing Cypher Query:

UNWIND [..., {
  "op": "merge",
  "properties": {
    "foo": "value",
    "key": 1
  },
  "ids": {"key": 1, "otherKey":  "foo"},
  "labels": ["Foo","Bar"],
  "type": "node",
  "detach": true
}, ...] AS event
MERGE (n:Foo:Bar {key: event.ids.key, otherKey: event.ids.otherKey})
SET n += event.properties

For more details please look into the documentation

• With #181 we validate a minimun amount of configuration params in orde to make the streams plugin work.

To get more info about it please look at the documentation.