接收器配置设置

org.neo4j.connectors.kafka.sink.Neo4jConnector

兼容的 Kafka Connect 转换器。

可以是以下之一；

消息键的模式注册表 URL。当配置的 key.converter 需要模式注册表时，需要此项。

当 key.converter 为 io.confluent.connect.protobuf.ProtobufConverter 时，应设置为 true。

兼容的 Kafka Connect 转换器。

可以是以下之一；

消息值的模式注册表 URL。当配置的 value.converter 需要模式注册表时，需要此项。

当 key.converter 为 io.confluent.connect.protobuf.ProtobufConverter 时，应设置为 true。

要连接到的 Neo4j URI。可以使用 , 分隔指定多个 URI。

要连接到的 Neo4j 数据库名称。建议明确指定。

要使用的身份验证类型。NONE、BASIC、KERBEROS、BEARER、CUSTOM 之一

默认值：BASIC

用于身份验证的用户名。当 neo4j.authentication.type 为 BASIC 时，需要此项。

用于身份验证的密码。当 neo4j.authentication.type 为 BASIC 时，需要此项。

用于身份验证的身份验证域，留空以使用默认值。

用于建立连接的 Kerberos 票据。当 neo4j.authentication.type 为 KERBEROS 时，需要此项。

用于建立连接的 Bearer 令牌。当 neo4j.authentication.type 为 BEARER 时，需要此项。

用于建立连接的自定义身份验证方案。当 neo4j.authentication.type 为 CUSTOM 时，需要此项。

用于建立连接的自定义主体。当 neo4j.authentication.type 为 CUSTOM 时，需要此项。

用于建立连接的自定义凭据。当 neo4j.authentication.type 为 CUSTOM 时，需要此项。

用于身份验证的自定义身份验证域，根据您的自定义身份验证提供程序的要求进行设置。

TCP 连接超时（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认值：30s（驱动程序默认值）

要保存在连接池中的最大连接数。

默认值：100（驱动程序默认值）

从连接池获取连接的最大等待时间（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认值：60s（驱动程序默认值）

空闲连接在测试其活动性之前持续的时间（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认值：不测试（驱动程序默认值）

连接从连接池中删除之前持续的时间（有效单位：`ms、s、m、h 和 d；默认单位为 s）。

默认值：1h（驱动程序默认值）

重试事务的最大持续时间。

默认值：30s

是否启用加密。仅当在 neo4j.uri 中使用 bolt 或 neo4j 方案时适用。true、false 之一

默认值：false。

用于 TLS 连接的信任策略。TRUST_ALL_CERTIFICATES、TRUST_SYSTEM_CA_SIGNED_CERTIFICATES、TRUST_CUSTOM_CA_SIGNED_CERTIFICATES 之一 当 neo4j.security.encrypted 为 true 时，需要此项。

默认值：TRUST_SYSTEM_CA_SIGNED_CERTIFICATES

包含要信任的 CA 的 X509 证书的文件列表。当 neo4j.security.trust-strategy 为 TRUST_CUSTOM_CA_SIGNED_CERTIFICATES 时，需要此项。

在 TLS 握手期间是否启用主机名验证。true、false 之一。

默认值：true

每个主题每个事务处理的最大消息数。

默认值：1000

批处理允许处理的最大时间（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认值：0s

要为指定主题运行的 Cypher 语句。例如："neo4j.cypher.topic.my-topic": "MERGE (n:Person {name: __value.name})"

在用户提供的 Cypher 语句中绑定消息时间戳的名称。设置为空字符串以禁用绑定消息时间戳。

默认值：__timestamp

在用户提供的 Cypher 语句中绑定消息头的名称。消息头将绑定为 header 名称到对应值的映射。设置为空字符串以禁用绑定消息头。

默认值：__header

在用户提供的 Cypher 语句中绑定消息键的名称。设置为空字符串以禁用绑定消息键。

默认值：__key

在用户提供的 Cypher 语句中绑定消息值的名称。设置为空字符串以禁用绑定消息值。

默认值：__value

消息值是否将在用户提供的 Cypher 语句中绑定为“事件”，以实现向后兼容性。

默认值：true

要应用于从指定主题接收的消息的节点或关系模式。例如："neo4j.pattern.topic.user": "(:User\{!userId})" 例如："neo4j.pattern.topic.user": "(:User\{!userId})-[:KNOWS]→(:User\{!otherUserId})"

是否将传入属性与节点的现有属性合并。

默认值：false

是否将传入属性与关系的现有属性合并。

默认值：false

在模式中绑定消息时间戳的名称。设置为空字符串以禁用绑定消息时间戳。

默认值：__timestamp

在模式中绑定消息头的名称。消息头将绑定为 header 名称到对应值的映射。设置为空字符串以禁用绑定消息头。

默认值：__header

在模式中绑定消息键的名称。设置为空字符串以禁用绑定消息键。

默认值：__key

在模式中绑定消息值的名称。设置为空字符串以禁用绑定消息值。

默认值：__value

包含此连接器的 Source 实例使用 CDC 源策略生成的 CDC 事件的主题。

包含此连接器的 Source 实例使用 CDC 源策略生成的 CDC 事件的主题。

由CDC Source Id策略管理的节点所附加的标签名称。

默认值：SourceEvent

由CDC Source Id策略管理的节点所附加的 ID 属性名称。

默认值：sourceId

包含 CUD 事件的主题。