Skip to content

Commit bfcc5a1

Browse files
ali-incefbivillenvitucci
authored
Release 5.1.8 (#67)
Co-authored-by: Florent Biville <445792+fbiville@users.noreply.github.com> Co-authored-by: Nicola Vitucci <nicola.vitucci@gmail.com>
1 parent c721351 commit bfcc5a1

File tree

5 files changed

+104
-2
lines changed

5 files changed

+104
-2
lines changed

‎antora.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ asciidoc:
1212
page-product: Neo4j Connector for Kafka
1313
kafka-connect-version: 3.0
1414
connector-version: '5.1'
15-
exact-connector-version: '5.1.7'
15+
exact-connector-version: '5.1.8'
1616
page-pagination: true
1717
product-name: Neo4j Connector for Kafka
1818
url-common-license-page: https://neo4j.com/docs/license/

‎modules/ROOT/content-nav.adoc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
** xref:sink/cdc.adoc[Change Data Capture]
2424
** xref:sink/pattern.adoc[Pattern]
2525
** xref:sink/cud.adoc[CUD]
26+
* xref:sink/connect-types.adoc[Type support]
2627
* xref:sink/error-handling.adoc[Error handling]
2728
* xref:sink/configuration.adoc[Settings]
2829

‎modules/ROOT/pages/changelog.adoc

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,44 @@
22

33
This page lists changes to the {product-name}.
44

5+
== Version 5.1.8
6+
7+
[cols="1,2", options="header"]
8+
|===
9+
| Feature | Details
10+
11+
a|
12+
label:functionality[]
13+
label:new[]
14+
15+
Support for `decimal`, `date`, `time` and `timestamp` Kafka Connect types in sink connector.
16+
a|
17+
When an incoming message contained one of the built-in Kafka Connect types (`decimal`, `date`, `time` and `timestamp`), the message could not be processed by the sink connector since it did not support these types.
18+
Support for these types is now made available.
19+
20+
[NOTE]
21+
====
22+
To avoid a data loss, `decimal` typed values are converted to `string` values.
23+
====
24+
25+
a|
26+
label:bug[]
27+
label:fixed[]
28+
29+
Rethrow exceptions if no errant record reporter is not set.
30+
| When a sink connector is configured without any error handling options, errant record reporter is not set by Kafka Connect and exceptions raised were silently ignored.
31+
These exceptions are no longer ignored, and re-thrown if no errant record reporter is set.
32+
33+
a|
34+
label:bug[]
35+
label:fixed[]
36+
37+
User provided Cypher queries that return results were failing in cypher sink strategy.
38+
| When a sink connector is configured with the Cypher strategy and the provided query included a `RETURN` clause, the internally re-written Cypher query was not being generated correctly and the connector ended up failing.
39+
The Cypher generation logic is now fixed and these type of queries are now supported.
40+
|===
41+
42+
543
== Version 5.1.7
644

745
This is a maintenance release which provides updated dependencies.

‎modules/ROOT/pages/sink.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,4 @@ Process incoming Kafka messages generated by either a Source instance configured
1414
xref:sink/pattern.adoc[Pattern]::
1515
Use a Cypher-like pattern syntax to transform incoming Kafka messages into Cypher write queries.
1616
xref:sink/cud.adoc[Create Update Delete (CUD) File]::
17-
Transform incoming CUD-formatted messages into Cypher write queries.
17+
Transform incoming CUD-formatted messages into Cypher write queries.

‎modules/ROOT/pages/sink/connect-types.adoc

Lines changed: 63 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,63 @@
1+
= Type support
2+
3+
The Sink connector supports the following built-in Kafka Connect types.
4+
5+
[cols="1,2",options="header"]
6+
|===
7+
| Kafka Connect type | Conversion rule
8+
9+
| Boolean
10+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[BOOLEAN] type.
11+
12+
| Bytes
13+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[BYTE ARRAY] type.
14+
15+
| Float32
16+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[FLOAT] type.
17+
18+
| Float64
19+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[FLOAT] type.
20+
21+
| Int8
22+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[INTEGER] type.
23+
24+
| Int16
25+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[INTEGER] type.
26+
27+
| Int32
28+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[INTEGER] type.
29+
30+
| Int64
31+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[INTEGER] type.
32+
33+
| String
34+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[STRING] type.
35+
36+
| Decimal
37+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#property-types[STRING] type.
38+
This is to avoid data loss, since Neo4j does not have native support for decimal values.
39+
40+
| Date
41+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/temporal/#_temporal_value_types[DATE] type.
42+
43+
| Time
44+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/temporal/#_temporal_value_types[LOCAL TIME] type.
45+
46+
| Timestamp
47+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/temporal/#_temporal_value_types[LOCAL DATETIME] type.
48+
49+
| Array
50+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#constructed-types[LIST] of converted elements.
51+
52+
| Map
53+
a| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#constructed-types[MAP] of keys to respective converted values.
54+
55+
[WARNING]
56+
====
57+
Incoming map values must have string-typed keys.
58+
====
59+
60+
| Struct
61+
| Converted into link:{page-canonical-root}/cypher-manual/current/values-and-types/property-structural-constructed/#constructed-types[MAP] of field name to respective converted values.
62+
63+
|===

0 commit comments

Comments
 (0)