3.4. Debezium JDBC 连接器配置属性的描述

name

没有默认值

连接器的唯一名称。如果您在注册连接器时尝试重复使用此名称，则失败结果。所有 Kafka Connect 连接器都需要此属性。

connector.class

没有默认值

连接器的 Java 类的名称。对于 Debezium JDBC 连接器，请指定值 io.debezium.connector.jdbc.JdbcSinkConnector。

tasks.max

1

此连接器使用的最大任务数量。

topics

没有默认值

要使用的主题列表，用逗号分开。不要将此属性与 topics.regex 属性结合使用。

topics.regex

没有默认值

指定要使用的主题的正则表达式。在内部，正则表达式编译到 java.util.regex.Pattern。不要将此属性与 topics 属性结合使用。

connection.provider

org.hibernate.c3p0.internal.C3P0ConnectionProvider

要使用的连接供应商实施。

connection.url

没有默认值

用于连接到数据库的 JDBC 连接 URL。

connection.username

没有默认值

连接器用来连接到数据库的数据库用户帐户的名称。

connection.password

没有默认值

连接器用来连接到数据库的密码。

connection.pool.min_size

5

指定池中最小连接数。

connection.pool.max_size

32

指定池维护的最大并发连接数。

connection.pool.acquire_increment

32

指定当连接池超过其最大大小时，连接器尝试获取的连接数量。

connection.pool.timeout

1800

指定在丢弃未使用的连接前保留的秒数。

database.time_zone

UTC

指定插入 JDBC 临时值时使用的时区。

delete.enabled

false

指定连接器是否处理 DELETE 或 tombstone 事件，并从数据库中删除对应的行。使用此选项要求您将 primary.key.mode 设置为 record.key。

truncate.enabled

false

指定连接器是否处理 TRUNCATE 事件，并截断数据库中的对应表。

insert.mode

insert

指定用于将事件插入到数据库中的策略。可用的选项如下：

primary.key.mode

none

指定连接器如何从事件解析主键列。

primary.key.fields

没有默认值

主键列的名称或以逗号分隔的字段列表，以便从中派生主密钥。

当 primary.key.mode 设置为 record_key 且事件的键是原语类型时，此属性指定要用于键的列名称。

当 primary.key.mode 设置为带有非原始键的 record_key 或 record_value 时，此属性指定来自 key 或 value 的以逗号分隔的字段名称列表。如果 primary.key.mode 设置为带有非原始键的 record_key，或 record_value，且此属性没有指定，则连接器会从记录键或记录值的所有字段生成主密钥，具体取决于指定的模式。

quote.identifiers

false

指定生成的 SQL 语句是否使用引号来分离表和列名称。详情请查看 第 3.1.9 节 “指定选项来定义目标表和列名称的字母大小写” 部分。

schema.evolution

none

指定连接器如何演变目标表模式。如需更多信息，请参阅 第 3.1.8 节 “Debezium JDBC 连接器的 schema evolution 模式”。可用的选项如下：

table.name.format

${topic}

根据事件的主题名称，指定确定目标表名称如何格式化的字符串。占位符 ${topic} 替换为主题名称。

dialect.postgres.postgis.schema

public

指定安装 PostgreSQL PostGIS 扩展的架构名称。默认为 public ；但是，如果在另一个架构中安装了 PostGIS 扩展，则此属性应该用于指定备用模式名称。

dialect.sqlserver.identity.insert

false

指定连接器是否在 INSERT 或 UPSERT 操作前自动设置 IDENTITY_INSERT 操作，然后在操作后立即取消设置它。当默认设置(false)生效时，INSERT 或 UPSERT 操作进入表的 IDENTITY 列中会导致 SQL 异常。

batch.size

500

指定在目标表中尝试批量批处理的记录数量。

field.include.list

空字符串

可选的、以逗号分隔的字段名称列表，与来自更改事件值的字段全限定名称匹配。字段的完全限定域名格式为 fieldName 或 topicName:_fieldName_。

如果您在配置中包含此属性，请不要设置 field.exclude.list 属性。

field.exclude.list

空字符串

可选的、以逗号分隔的字段名称列表，与从更改事件值中排除的字段全限定名称匹配。字段的完全限定域名格式为 fieldName 或 topicName:_fieldName_。

如果您在配置中包含此属性，请不要设置 field.include.list 属性。

column.naming.strategy

i.d.c.j.n.DefaultColumnNamingStrategy

指定连接器用来从事件字段名称解析列名称的 ColumnNamingStrategy 实现的完全限定类名称。

默认情况下，连接器使用字段名称作为列名称。

table.naming.strategy

i.d.c.j.n.DefaultTableNamingStrategy

指定 TableNamingStrategy 实现的完全限定类名称，连接器用来从传入的事件主题名称解析表名称。

默认行为是：