源配置设置

org.neo4j.connectors.kafka.source.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 时需要。

用于建立连接的承载令牌。当 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

此连接器的源策略。CDC、QUERY 之一。

开始流式传输的时间锚点。EARLIEST、NOW、USER_PROVIDED 之一。仅在连接器实例的初始运行时使用，并且在 Kafka Connect 中已存在存储的偏移量时忽略。

默认：NOW

用作起始偏移量的自定义值。当 neo4j.start-from 设置为 USER_PROVIDED 时需要。

是否忽略从上次运行保存的偏移量存储中检索到的任何偏移量值。true、false 之一。

默认：false

每个轮询周期发布的最大更改事件数。

默认：1000

定义更改消息的结构。COMPACT、EXTENDED 之一。COMPACT 提供更简单的消息，但如果属性类型发生更改，则会遇到模式兼容性问题。EXTENDED 包括类型信息以避免此类问题。

默认：EXTENDED。

CDC 主题密钥的序列化策略。SKIP、ELEMENT_ID、ENTITY_KEYS、WHOLE_VALUE 之一。

默认：WHOLE_WALUE

CDC 主题密钥的序列化策略。CHANGE_EVENT、ENTITY_EVENT 之一。

默认：CHANGE_EVENT

注意：如果您使用的是具有 CDC 策略之一的接收器连接器，则此设置必须配置为 CHANGE_EVENT。

Kafka Connect 轮询请求等待从数据库接收更改的最大时间量（有效单位：ms、s、m、h 和 d；默认单位为 s）

默认：5s

在 neo4j.cdc.poll-duration 期间数据库轮询更改的间隔（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认：1s

用逗号分隔的图模式列表，以及可选的事件属性过滤器（以 + 或 - 为前缀，分别表示包含或排除）。

示例设置："neo4j.cdc.topic.my-topic.patterns": "(:Person {+name}),(:Person)-[:WORKS_FOR]→(:Company),(:Company {-id})"。Company 节点的更改事件不会包含 id 属性。

索引的图模式，以及可选的事件属性过滤器（以 + 或 - 为前缀，分别表示包含或排除）。

示例："neo4j.cdc.topic.my-topic.patterns.0.pattern": "(:Company {+name})"。针对Company节点的变更事件将始终包含name属性（在 CDC FULL 丰富模式下），或者当name属性发生变化时（在 CDC DIFF 丰富模式下）。

CREATE、UPDATE、DELETE 之一。针对相应索引图模式，我们希望接收其变更事件的操作。

示例："neo4j.cdc.topic.my-topic.patterns.0.operation": "DELETE"

用逗号分隔的属性名称列表。

示例："neo4j.cdc.topic.my-topic.patterns.0.changesTo": "name, age"（参见 选择器如何组合）

执行变更时已验证身份的用户。

示例："neo4j.cdc.topic.my-topic.patterns.0.metadata.authenticatedUser": "userA"

执行变更时执行事务的用户。通常与authenticatedUser相同，但如果使用用户模拟，则可能发生变化。

示例："neo4j.cdc.topic.my-topic.patterns.0.metadata.executingUser": "userB"

键值事务元数据选择器。键值对与实际事务元数据匹配（键去掉了上述前缀）。

示例："neo4j.cdc.topic.my-topic.patterns.0.metadata.txMetadata.app": "neo4j-browser"

发布通过提供的查询收集的变更事件的 Kafka 主题。

用于收集变更的 Cypher 查询。需要结果集中同时存在neo4j.query.streaming-property 和用于跟踪变更的$lastCheck 查询参数。

属性名称，该名称既存在于指定查询的结果集中，也用作从先前值查询变更的过滤器。

默认：timestamp

Kafka Connect 轮询请求等待从数据库接收变更的最大时间量（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认：5s

在neo4j.query.poll-duration期间数据库轮询变更的间隔（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认：1s

查询允许运行的最大时间量（有效单位：ms、s、m、h 和 d；默认单位为 s）。

默认：0s