Source: https://dev-docs.yueshu.com.cn/v5.3.2/clients/kafka-connector/kafka-options/
Documentation version: v5.3.2

# 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