源配置设置
连接器设置
名称 | 描述 |
---|---|
|
|
|
一个兼容的 Kafka Connect 转换器。 可以是以下之一:
|
|
消息键的 Schema Registry URL。当配置的 |
|
当 |
|
一个兼容的 Kafka Connect 转换器。 可以是以下之一:
|
|
消息值的 Schema Registry URL。当配置的 |
|
当 |
Neo4j 连接设置
名称 | 描述 |
---|---|
|
要连接的 Neo4j URI。可以指定多个 URI,用 |
|
要连接的 Neo4j 数据库名称。建议明确指定。 |
|
要使用的认证类型。可以是 默认值: |
|
用于认证的用户名。当 |
|
用于认证的密码。当 |
|
用于认证的认证域,留空表示使用默认值。 |
|
用于建立连接的 Kerberos 票据。当 |
|
用于建立连接的 Bearer 令牌。当 |
|
用于建立连接的自定义认证方案。当 |
|
用于建立连接的自定义主体。当 |
|
用于建立连接的自定义凭据。当 |
|
用于认证的自定义认证域,根据您的自定义认证提供商的要求进行设置。 |
|
TCP 连接超时(有效单位为: 默认值: |
|
连接池中保持的最大连接数。 默认值: |
|
从连接池获取连接的最大等待时间(有效单位为: 默认值: |
|
空闲连接在多久后进行存活测试(有效单位为: 默认值: |
|
连接从连接池中丢弃的时间长度(有效单位为: 默认值: |
|
重试事务的最大持续时间。 默认值: |
|
是否启用加密。仅当 默认值: |
|
TLS 连接要使用的信任策略。可以是 默认值: |
|
包含要信任的 CA 的 X509 证书的文件列表。当 |
|
在 TLS 握手期间是否启用主机名验证。可以是 默认值: |
通用源设置
名称 | 描述 |
---|---|
|
此连接器的源策略。可以是 |
|
开始流式传输的时间锚点。可以是 默认值: |
|
用作起始偏移量的自定义值。当 |
|
是否忽略从上次运行保存的偏移量存储中检索到的任何偏移量值。可以是 默认值: |
|
每个轮询周期发布的最大变更事件数。 默认值: |
|
定义变更消息的结构。可以是 默认值: |
CDC 策略设置
名称 | 描述 |
---|---|
|
CDC 主题键的序列化策略。可以是 默认值: |
|
CDC 主题值的序列化策略。可以是 默认值: 注意: 如果您使用带有 CDC 策略之一的目标连接器,此设置必须配置为 |
|
Kafka Connect 轮询请求等待从数据库接收变更的最大时间量(有效单位为: 默认值: |
|
在 默认值: |
|
逗号分隔的图模式列表,带有可选事件属性过滤器(分别以 示例设置: |
|
索引图模式,带有可选事件属性过滤器(分别以 示例: |
|
可以是 示例: |
|
逗号分隔的属性名称列表。 示例: |
|
执行变更时已认证的用户。 示例: |
|
执行变更时正在执行事务的用户。通常与 示例: |
|
键值事务元数据选择器。键值对与实际事务元数据匹配(键已去除上述前缀)。 示例: |
QUERY
策略设置
名称 | 描述 |
---|---|
|
Kafka 主题,用于发布通过提供的查询收集的变更事件。 |
|
用于收集变更的 Cypher 查询。要求 |
|
属性名称,它既存在于指定查询的结果集中,又用作从先前值查询变更的过滤器。 默认值: |
|
Kafka Connect 轮询请求等待从数据库接收变更的最大时间量(有效单位为: 默认值: |
|
在 默认值: |
|
查询允许运行的最大时间量(有效单位为: 默认值: |