类型支持

Sink 连接器支持以下内置的 Kafka Connect 类型。

Kafka Connect 类型 转换规则

布尔值

转换为 BOOLEAN 类型。

Bytes

转换为 BYTE ARRAY 类型。

Float32

转换为 FLOAT 类型。

Float64

转换为 FLOAT 类型。

Int8

转换为 INTEGER 类型。

Int16

转换为 INTEGER 类型。

Int32

转换为 INTEGER 类型。

Int64

转换为 INTEGER 类型。

字符串

转换为 STRING 类型。

Decimal

转换为 STRING 类型。这样做是为了避免数据丢失，因为 Neo4j 并不原生支持十进制值。

Date

转换为 DATE 类型。

Time

转换为 LOCAL TIME 类型。

Timestamp

转换为 LOCAL DATETIME 类型。

Array（数组）

转换为 LIST（已转换元素的列表）。

Map

转换为 MAP（键映射到各自已转换的值）。

传入的 map 值必须使用字符串类型的键。

Struct

转换为 MAP（字段名映射到各自已转换的值）。