Sink 配置设置

org.neo4j.connectors.kafka.sink.Neo4jConnector

兼容的 Kafka Connect 转换器。

可以是以下之一；

消息键的 Schema Registry URL。当配置的 key.converter 需要 Schema Registry 时为必填项。

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

兼容的 Kafka Connect 转换器。

可以是以下之一；

消息值的 Schema Registry URL。当配置的 value.converter 需要 Schema Registry 时为必填项。

当 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）。

默认值: no test (驱动默认)

连接从连接池中丢弃的时长（有效单位为：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

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

默认值: __key

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

默认值: __value

为了向后兼容，消息值是否在用户提供的 Cypher 语句中绑定为 'event'。

默认值: true

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

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

默认值: false

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

默认值: false

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

默认值: __timestamp

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

默认值: __header

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

默认值: __key

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

默认值: __value

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

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

附加到 CDC 源 ID 策略管理的节点的标签名称。

默认值: SourceEvent

附加到 CDC 源 ID 策略管理的节点的 ID 属性名称。

默认值: sourceId

包含 CUD 事件的主题。