3.5.5
Hello Neo4j Community!
We're very happy to present the new 3.5.5 release of the Neo4j Kafka integrations, that is the result of great community feedback!
Thanks a lot to everyone who contributed to this: @moxious, @jexp, @conker84 and @F-Guardian
Following a list of improvements:
-
with
fixes #252: Source with non-existant topic hangs indefinitely (#257)
we improved the behaviour in case the BROKER configauto.create.topics.enable
is false and you're sending an event to a topic that is not created in the Kafka cluster. If you're publish events to a topic that is not created theProducer#send
can block until the timeout defined bymax.block.ms
, so we add a system that checks every topic defined in the Kafka Cluster and log if the topic that you defined into yourneo4j.conf
file exist. -
with
fixes #247: Schema Ingestion Strategy: double node creation (#248)
we fixed a bug where, under particular circumstances, can lead to a double node creation in case you're ingesting data with theSchema ingestion strategy
-
with
Fixes an issue with wrong ids value in cdc when updating relationships
we fixed a bug where that could lead to stream wrong ids for the target node while you're updating relationships
Other fixes:
- fix typo in documentation section 4.2 (#253)
- fixes #249: Correct typo in DLQ property (#262)
- fixes #259: Fix Kafka plugin version (#260)
- fixes #264: Neo4j Sink Connector: CDC ingestion with schema strategy
To get more info about it please look at the documentation.