Kafka 连接器配置¶

本文介绍悦数图数据库开发版 Kafka 连接器的配置。

配置参数¶

参数	描述	是否必选	默认值	数据类型
`name`	连接器的名称。	是	无	String
`connector.class`	连接器的入口类。设置为`com.vesoft.nebula.connector.sink.NebulaSinkConnector`。	是	无	String
`tasks.max`	可为连接器创建的最大任务数。	是	无	Integer
`topics`	从中接收数据到悦数图数据库开发版的 Kafka 主题。多个主题之间用英文逗号分隔。	是	无	String
`nebula.graph.servers`	Graph 服务的 IP 和端口。多个地址之间用英文逗号分隔。	是	无	String
`nebula.user`	Graph 服务的用户名。	是	无	String
`nebula.passwd`	用户的密码。在未指定`nebula.authOptions`时必填。	否	无	String
`nebula.authOptions`	用户的认证信息。对于密码认证，认证信息必须遵循格式`{password:<password>}`。在未指定`nebula.passwd`时必填。	否	无	String
`nebula.schema`	从连接器接收数据的 Schema。若未指定，则使用悦数图数据库开发版中的主 Schema。	否	无	String
`nebula.date.format`	当前会话的日期格式。若未指定，则使用悦数图数据库开发版中设置的日期格式。	否	无	String
`nebula.zonedDatetime.format`	当前会话的时区日期时间格式。若未指定，则使用悦数图数据库开发版中设置的时区日期时间格式。	否	无	String
`nebula.localDatetime.format`	当前会话的本地日期时间格式。若未指定，则使用悦数图数据库开发版中设置的本地日期时间格式。	否	无	String
`nebula.zonedTime.format`	当前会话的时区时间格式。若未指定，则使用悦数图数据库开发版中设置的时区时间格式。	否	无	String
`nebula.localTime.format`	当前会话的本地时间格式。若未指定，则使用悦数图数据库开发版中设置的本地时间格式。	否	无	String
`nebula.enable.tls`	是否启用 TLS 加密。	否	`false`	Boolean
`nebula.disable.verify.cert`	是否禁用服务器证书校验。	否	`false`	Boolean
`nebula.tls.ca.path`	用于校验服务器证书的 CA 证书文件的路径。如果`nebula.enable.tls`设置为`true`且`nebula.disable.verify.cert`设置为`false`，则此项必填。	否	无	String
`nebula.tls.cert.path`	客户端证书文件的路径。如果悦数图数据库开发版的 Graph 服务的配置文件里将`tls_client_verify`设置为`true`，则此项必填。	No	无	String
`nebula.tls.key.path`	客户端私钥文件的路径。如果悦数图数据库开发版的 Graph 服务的配置文件里将`tls_client_verify`设置为`true`，则此项必填。	No	无	String
`nebula.connect.timeout`	连接 Graph 服务的超时时间（毫秒）。	否	`3000`	Integer
`nebula.request.timeout`	每个 Graph 服务请求的超时时间（毫秒）。	否	`3000`	Integer
`nebula.sink.partitions`	连接器的分区数。	否	`10`	Integer
`nebula.sink.interval.time.mills`	连接器在接收数据失败后重试的时间间隔（毫秒）。	否	`0`	Integer
`nebula.sink.retry.times`	连接器在接收数据失败后最大重试次数。	否	`0`	Integer
`nebula.graph.name`	从连接器接收数据的目标图的名称。	是	无	String
`nebula.data.type`	图中的图元素类型。有效值为`NODE`、`EDGE`和`BOTH`。	否	`NODE`	String
`nebula.node.typeName`	从连接器接收数据的点类型的名称。当`nebula.data.type`设置为`NODE`或`BOTH`时必填。	否	无	String
`nebula.node.primaryKeys`	构成点类型主键的属性。当`nebula.data.type`设置为`NODE`或`BOTH`且主键由多个属性组成时，该选项必填。	否	无	LIST
`kafka.node.primaryKeys`	Kafka 主题中作为点类型的主键的属性写入的字段。字段的顺序必须与`nebula.node.primaryKeys`中属性的顺序匹配。当`nebula.data.type`设置为`NODE`或`BOTH`且`nebula.sink.mode`设置为`UPDATE`或`DELETE`时，该选项必填。	否	无	LIST
`nebula.node.property.names`	从连接器接收数据的点类型的属性。当`nebula.data.type`设置为`NODE`或`BOTH`时必填。	否	无	LIST
`kafka.node.property.names`	Kafka 主题中作为点类型的属性写入的字段。字段的顺序必须与`nebula.node.property.names`中属性的顺序匹配。当`nebula.data.type`设置为`NODE`或`BOTH`时，该选项必填。	否	无	LIST
`nebula.edge.typeName`	从连接器接收数据的边类型的名称。当`nebula.data.type`设置为`EDGE`或`BOTH`时，该选项必填。	否	无	String
`nebula.edge.srcPks`	构成边类型起始点的主键的属性。当`nebula.data.type`设置为`EDGE`或`BOTH`且主键由多个属性组成时，该选项必填。	否	无	LIST
`kafka.edge.srcPks`	Kafka 主题中作为边类型起始点的主键的属性写入的字段。字段的顺序必须与`nebula.edge.srcPks`中属性的顺序匹配。当`nebula.data.type`设置为`EDGE`或`BOTH`时，该选项必填。	否	无	LIST
`nebula.edge.dstPks`	构成边类型目标点的主键的属性。当`nebula.data.type`设置为`EDGE`或`BOTH`且主键由多个属性组成时，该选项必填。	否	无	LIST
`kafka.edge.dstPks`	Kafka 主题中作为边类型目标点的主键的属性写入的字段。字段的顺序必须与`nebula.edge.dstPks`中属性的顺序匹配。当`nebula.data.type`设置为`EDGE`或`BOTH`时，该选项必填。	否	无	LIST
`nebula.edge.property.names`	从接收器接收数据的边类型的属性。当`nebula.data.type`设置为`EDGE`或`BOTH`时，该选项必填。	否	无	LIST
`kafka.edge.property.names`	Kafka 主题中作为边类型的属性写入的字段。字段的顺序必须与`nebula.edge.property.names`中属性的顺序匹配。当`nebula.data.type`设置为`EDGE`或`BOTH`时，该选项必填。	否	无	LIST
`nebula.batchSize`	悦数图数据库开发版接收数据时每个请求中处理的点和边的总数。	否	`2000`	Integer
`nebula.sink.mode`	悦数图数据库开发版接收数据时的数据操作模式。可选值包括：`INSERT`、`INSERTIGNORE`、`INSERTREPLACE`、`UPDATE`、`DELETE`及`DETACHDELETE`.	否	`INSERTIGNORE`	String
`kafka.null.value`	Kafka 主题中被视为`null`的字段值。	否	`\N`	String
`key.converter`	覆盖 Kafka worker 设置的默认键转换器类的转换器类。	否	`org.apache.kafka.connect.storage.StringConverter`	String
`value.converter`	覆盖 Kafka worker 设置的默认值转换器类的转换器类。	否	`org.apache.kafka.connect.storage.StringConverter`	String