Type support
The Sink connector supports the following built-in Kafka Connect types.
| Kafka Connect type | Conversion rule | ||
|---|---|---|---|
Boolean |
Converted into BOOLEAN type. |
||
Bytes |
Converted into BYTE ARRAY type. |
||
Float32 |
Converted into FLOAT type. |
||
Float64 |
Converted into FLOAT type. |
||
Int8 |
Converted into INTEGER type. |
||
Int16 |
Converted into INTEGER type. |
||
Int32 |
Converted into INTEGER type. |
||
Int64 |
Converted into INTEGER type. |
||
String |
Converted into STRING type. |
||
Decimal |
Converted into STRING type. This is to avoid data loss, since Neo4j does not have native support for decimal values. |
||
Date |
Converted into DATE type. |
||
Time |
Converted into LOCAL TIME type. |
||
Timestamp |
Converted into LOCAL DATETIME type. |
||
Array |
Converted into LIST of converted elements. |
||
Map |
Converted into MAP of keys to respective converted values.
|
||
Struct |
Converted into MAP of field name to respective converted values. |