Changelog
This page lists changes to the Neo4j Connector for Kafka.
Version 5.1.5
New and Updated Features
Feature | Details |
---|---|
Functionality New Added |
Introduced the |
Bug Fixed Prevented exception caused by adding duplicate fields in schema generation for CDC source events. |
Resolved an issue in the ChangeEvent schema generation process where duplicate fields were causing an exception ( |
Version 5.1.4
New and updated features
Feature | Details |
---|---|
Bug Fixed Fixed a bug in the CDC schema sink connector where relationship update and delete events without any start or end node keys incorrectly generated Cypher statements. |
Resolved an issue where messages referring to relationship update and delete events, which do not contain any start or end node keys, generate Cypher statements that update or delete wider entities on the target database. These messages now generate a failure which should be handled through usual error handling mechanisms. |
Version 5.1.3
New and updated features
Feature | Details |
---|---|
Bug Fixed Fixed a bug in the Sink connector where messages without valid constraints would not be processed. |
Resolved an issue where messages created from the |
Version 5.1.2
New and updated features
Feature | Details |
---|---|
Fix Support JSON strings with JsonConverter when schemas are not enabled |
Resolved an issue with the |
Version 5.1.1
New and updated features
Feature | Details |
---|---|
Fix Updated the Neo4j driver to mitigate Netty’s CVE-2023-34462. |
The Neo4j driver has been updated to the latest 4.4.x version (4.4.18), which includes a fix for Netty’s CVE-2023-34462. |
Version 5.1.0
New and updated features
Feature | Details |
---|---|
Feature New Added value serialisation strategies for CDC source messages. |
We’ve introduced an optional property |
Version 5.1.0-rc02
New and updated features
Feature | Details |
---|---|
Functionality Breaking Schema shape for change events generated by the Source connector is changed in a way that’s not compatible with earlier versions. |
In earlier versions of Neo4j Connector for Kafka, the Source connector derived Kafka Connect structs to express entity properties, which had limitations around schema compatibility over property type changes. Schema derivation logic is now updated to encode type information into a dedicated struct so that this limitation no longer applies. |
Functionality New Pattern sink strategy now checks for matching key constraint for properties marked as key. |
Added a new check into pattern sink strategy handlers, which will now verify if there is a matching constraint for properties marked as key in provided patterns. If no matching constraint is found, it is logged as a message into Kafka Connect logs. |
Configuration Changed Renamed following sink configuration properties:
|
Improved Pattern sink configuration so that there is no need to specify pattern type as part of the configuration property name. |
Version 5.1.0-rc01
New and updated features
Feature | Details |
---|---|
Feature New Added support for error handling in sink connector. |
The Sink connector now has proper error handling in-place so that it can make use of Kafka Connect error handling configuration and direct failing messages into a DLQ. |
Configuration Removed Removed following source properties:
Removed following sink properties:
|
The new version of source connector always generates messages with schema support. To disable schemas, configure your key and value converters accordingly. The new version of sink connector does not implement any parallelization logic, and processes changes in the order they appear in the topic. |
Configuration Changed Renamed the following configuration properties:
|
The |
Feature Configuration New Added new sink properties:
Added new source properties:
|
Cypher strategy now also allows binding of message timestamp in user provided Cypher queries. Node and relationship pattern strategies now allow binding of message timestamp, headers, key and value as separate and configurable variables in user provided patterns. Query source strategy is re-implemented so that a |
Feature New Revamped pattern strategies in sink connector. |
Node and relationship pattern sink strategies have been re-implemented with several improvements.
|
Version 5.1.0-beta02
New and updated features
Feature | Details | ||
---|---|---|---|
Feature New Added new sink properties:
|
Cypher strategy now allows binding of message headers, key and value as separate and configurable variables to be used in user provided Cypher queries. |
||
Fix Breaking Schema conversion of Cypher types |
A problem in conversion of Cypher values from Connect values, which are defined as custom Connect types (like This had been causing problems when using Protobuf converters.
|
Version 5.1.0-beta01
New and updated features
Feature | Details |
---|---|
Feature New CDC message support for sink connector |
Both the new CDC message format available in Neo4j Aura 5 and latest Neo4j 5.x Enterprise Edition, and old streams change message format are now supported in CDC |
Configuration Changed Some |
In order to provide consistent and more intuitive naming we have renamed some
|
Version 5.1.0-alpha03
New and updated features
Feature | Details |
---|---|
Configuration Changed Some |
In order to provide consistent and more intuitive naming we have renamed some
|
Functionality Changed Schema for CDC events is updated. |
We have updated a schema to be compatible for |
Bug Fixed Fixed a bug with how CDC index pattern configuration is parsed |
Previously it would be possible to receive an error if multiple continuous indexes were specified |
Version 5.1.0-alpha02
New and updated features
Feature | Details |
---|---|
Feature New Added key serialisation strategies for CDC source messages. |
We’ve introduced an optional property |
Functionality Changed Supports new |
Neo4j 5.15 introduced a breaking change on change event schema, where the structure of the |