7.6. 部署 Debezium PostgreSQL 连接器

没有默认值 连接器的唯一名称。尝试使用相同的名称再次注册将失败。所有 Kafka Connect 连接器都需要此属性。 connector.class 没有默认值 连接器的 Java 类的名称。始终为 PostgreSQL 连接器使用 io.debezium.connector.postgresql.PostgresConnector 值。 tasks.max 应该为此连接器创建的最大任务数量。PostgreSQL 连接器始终使用单个任务，因此不使用这个值，因此默认值始终可以接受。 plugin.name decoderbufs 在 PostgreSQL 服务器上安装的 PostgreSQL 逻辑解码插件的名称 。 唯一支持的值是 pgoutput 。您必须将 plugin.name 明确设置为 pgoutput 。 slot.name Debezium 为流传输特定数据库/schema 的特定插件创建的 PostgreSQL 逻辑解码插槽的名称。服务器使用此插槽将事件流传输到您要配置的 Debezium 连接器。 插槽名称必须符合 PostgreSQL 复制插槽命名规则 ， 其状态为 "每个复制插槽名称，其中可以包含小写字母、数字和下划线字符"。 slot.drop.on.stop false 当连接器以安全、预期的方式停止时，是否删除逻辑复制插槽。默认行为是，当连接器停止时为连接器配置复制插槽。当连接器重启时，具有相同复制插槽可让连接器开始处理它的位置。 仅在测试或开发环境中设置为 true 。丢弃插槽可让数据库丢弃 WAL 段。当连接器重启它执行新快照时，或者可以从 Kafka Connect offsets 主题中的持久偏移继续。 publication.name dbz_publication 使用 pgoutput 时创建的用于流更改的 PostgreSQL 发布的名称。 如果尚未存在，则在启动时创建此发布，并且 包括所有表 。然后，Debezium 应用自己的 include/exclude 列表过滤（如果已配置），以限制发布以更改感兴趣的事件。连接器用户必须具有创建此出版物的超级用户权限，因此通常最好在第一次启动连接器前创建发布。 如果发布已存在，可以是所有表，或配置了表子集，Debebe 会使用发布，因为它被定义。 database.hostname 没有默认值 PostgreSQL 数据库服务器的 IP 地址或主机名。 database.port PostgreSQL 数据库服务器的整数端口号。 database.user 没有默认值 用于连接到 PostgreSQL 数据库服务器的 PostgreSQL 数据库用户的名称。 database.password 没有默认值 连接到 PostgreSQL 数据库服务器时要使用的密码。 database.dbname 没有默认值 从中流传输更改的 PostgreSQL 数据库的名称。 topic.prefix 没有默认值 为特定 PostgreSQL 数据库服务器或集群提供命名空间的主题前缀，其中 Debezium 正在捕获更改。前缀应该在所有其他连接器中唯一，因为它被用作从这个连接器接收记录的所有 Kafka 主题的主题名称前缀。数据库服务器逻辑名称中只能使用字母数字字符、连字符、句点和下划线。

不要更改此属性的值。如果您重启后更改了 name 值，而不是继续向原始主题发出事件，连接器会将后续事件发送到名称基于新值的主题。 schema.include.list 没有默认值 可选的、以逗号分隔的正则表达式列表， 与您要 捕获更改的模式名称匹配。不包括在 schema. include.list 中的任何架构 名称都会从捕获其更改中排除。默认情况下，所有非系统模式都会捕获其更改。
要匹配 schema 的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与 schema 的整个标识符匹配；它与 schema 名称中可能存在的子字符串匹配。
如果您在配置中包含此属性，不要设置 schema.exclude.list 属性。 schema.exclude.list 没有默认值 可选的、以逗号分隔的正则表达式列表，与 您不想 捕获更改的模式名称匹配。任何名称不包含在 schema. exclude.list 中的模式 ，其更改会被捕获，但系统模式除外。
要匹配 schema 的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与 schema 的整个标识符匹配；它与 schema 名称中可能存在的子字符串匹配。
如果您在配置中包含此属性，请不要设置 schema.include.list 属性。 table.include.list 没有默认值 可选的、以逗号分隔的正则表达式列表，与您要捕获的表的完全限定表标识符匹配。当设置此属性时，连接器只捕获指定表中的更改。每个标识符都是 schemaName . tableName 。默认情况下，连接器在每个捕获了其更改的每个模式中捕获每个非系统表中的更改。
要匹配表的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与表的完整标识符匹配；它与表名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，不要设置 table.exclude.list 属性。 table.exclude.list 没有默认值 可选的、以逗号分隔的正则表达式列表，与您不想捕获的表的完全限定表标识符匹配。每个标识符都是 schemaName . tableName 。当设置此属性时，连接器会捕获您未指定的每个表的更改。
要匹配表的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与表的完整标识符匹配；它与表名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，请不要设置 table.include.list 属性。 column.include.list 没有默认值 可选的、以逗号分隔的正则表达式列表，与更改事件记录值中包含的列的完全限定域名匹配。列的完全限定域名格式为 schemaName . tableName . columnName 。
要匹配列的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，表达式用于匹配列的整个名称字符串；它与列中可能出现的子字符串不匹配。
如果您在配置中包含此属性，不要设置 column.exclude.list 属性。 column.exclude.list 没有默认值 可选的、以逗号分隔的正则表达式列表，与更改事件记录值中排除的列的完全限定域名匹配。列的完全限定域名格式为 schemaName . tableName . columnName 。
要匹配列的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，表达式用于匹配列的整个名称字符串；它与列中可能出现的子字符串不匹配。
如果您在配置中包含此属性，请不要设置 column.include.list 属性。 skip.messages.without.change false 指定在包含列中没有更改时是否跳过发布消息。如果列中没有包括每个 column.include.list 或 column.exclude.list 属性的列有变化，这将过滤消息。 注：仅在表的 REPLICA IDENTITY 设置为 FULL 时有效 time.precision.mode adaptive 时间、日期和时间戳可以通过不同类型的精度来表示：

adaptive 使用 millisecond、microsecond 或 nanosecond 精度值，根据数据库列的类型的类型来捕获日期、日期和时间戳。

adaptive_time_microseconds 使用 millisecond、microsecond 或 nanosecond 精度来捕获数据库中的日期、日期和时间戳值。一个例外是 TIME 类型字段，它总是被捕获为微秒。

connect 始终通过使用 Kafka Connect 的内置表示表示 Time , Date , 和 Timestamp 的值，无论数据库列的精度是什么。如需更多信息，请参阅 临时值 。 decimal.handling.mode 指定连接器应该如何处理 DECIMAL 和 NUMERIC 列的值：

precise 代表使用 java.math.BigDecimal 来以二进制形式代表改变事件的值。

double 代表使用 double 值来代表值。它可能会降低一些精度，但更加容易使用。

string 以特定格式的字符串来对值进行编码。这容易使用，但其代表的真实类型的信息可能会丢失。如需更多信息，请参阅 Decimal type 。 hstore.handling.mode 指定连接器应该如何处理 hstore 列的值：

map 代表使用 MAP 。

json 代表使用 json 字符串 代表值。此设置对格式的字符串进行编码，如 {"key" : "val"} 。如需更多信息，请参阅 PostgreSQL HSTORE 类型 。 interval.handling.mode 指定连接器如何处理 interval 列的值：

numeric 代表使用大约微秒数的间隔。

string 代表间隔，使用 P<years>Y<months>M<days>DT<hours>H<minutes>M<seconds>S 代表。例如： P1Y2M3DT4H5M6.78S 。如需更多信息，请参阅 PostgreSQL 基本类型 。 database.sslmode prefer 是否使用到 PostgreSQL 服务器的加密连接。options include:

disable 使用未加密的连接。

允许 首先尝试使用未加密的连接，失败，失败（安全（加密）连接。

首选 尝试先使用安全（加密）连接，失败，未加密的连接失败。

需要使用 安全（加密）连接，如果出现以下情况，则会失败。 无法建立。

verify-ca 的行为与 require 一样，但也会根据配置的证书颁发机构(CA)证书验证服务器 TLS 证书。 如果没有找到有效的匹配 CA 证书，

verify-full 的行为与 verify-ca 类似，但也验证服务器证书是否与连接器尝试连接的主机匹配。如需更多信息 ，请参阅 PostgreSQL 文档 。 database.sslcert 没有默认值 包含客户端的 SSL 证书的文件的路径。如需更多信息 ，请参阅 PostgreSQL 文档 。 database.sslkey 没有默认值 包含客户端的 SSL 私钥的文件的路径。如需更多信息 ，请参阅 PostgreSQL 文档 。 database.sslpassword 没有默认值 从 database.sslkey 指定的文件访问客户端私钥的密码。如需更多信息 ，请参阅 PostgreSQL 文档 。 database.sslrootcert 没有默认值 包含验证服务器的根证书的文件的路径。如需更多信息 ，请参阅 PostgreSQL 文档 。 database.tcpKeepAlive 启用 TCP keep-alive 探测，以验证数据库连接是否仍然处于活动状态。如需更多信息 ，请参阅 PostgreSQL 文档 。 tombstones.on.delete 控制 delete 事件是否后跟一个 tombstone 事件。

true - 一个 delete 操作由 delete 事件和后续 tombstone 事件表示。

false - 仅有一个 delete 事件被抛出。

删除源记录后，发出 tombstone 事件（默认行为）可让 Kafka 在为主题启用了 日志 压缩时完全删除与已删除行键相关的所有事件。 column.truncate.to. length .chars 可选的、以逗号分隔的正则表达式列表，与基于字符列的完全限定名称匹配。如果在列中的数据超过了在属性名中的 length 指定的字符长度时删节数据，设置此属性。将 length 设置为正整数值，如 column.truncate.to.20.chars 。 列的完全限定域名会观察以下格式：< schemaName> . < tableName&gt ; . & lt; columnName&gt ;。要匹配列的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与列的整个名称字符串匹配；表达式与列名称中可能存在的子字符串不匹配。 您可以在单个配置中指定多个长度不同的属性。 column.mask.with. length .chars 可选的、以逗号分隔的正则表达式列表，与基于字符列的完全限定名称匹配。如果您希望连接器屏蔽一组列的值，例如，如果它们包含敏感数据，则设置此属性。将 length 设置为一个正整数，替换在属性名称中的 length 指定的星号（ * ）的数量列中的数据。将 length 设置为 0 （零）将指定列中的数据替换为空字符串。 列的完全限定域名观察以下格式： schemaName . tableName . columnName 。要匹配列的名称，Debebe 会使用正则表达式，它由您作为 anchored 正则表达式指定。也就是说，指定的表达式与列的整个名称字符串匹配；表达式与列名称中可能存在的子字符串不匹配。 您可以在单个配置中指定多个长度不同的属性。 column.mask.hash. hashAlgorithm .with.salt. salt ; column.mask.hash.v2. hashAlgorithm .with.salt. salt 可选的、以逗号分隔的正则表达式列表，与基于字符列的完全限定名称匹配。列的完全限定域名格式为 <schemaName> . <tableName> . <columnName> .
要匹配一个列的名称，Debezium 应用正则表达式，它由您指定为 anchored 正则表达式。也就是说，指定的表达式与列的整个名称字符串匹配；表达式与列名称中可能存在的子字符串不匹配。在生成的更改事件记录中，指定列的值替换为 pseudonyms。
一个 pseudonym，它包括了通过应用指定的 hashAlgorithm 和 salt 的结果的哈希值。根据所使用的哈希函数，会维护引用完整性，而列值则替换为 pseudonyms。支持的哈希功能在 Java Cryptography 架构标准 Algorithm Name 文档的 MessageDigest 部分中 进行了描述。

在以下示例中， CzQMA0cB5K 是一个随机选择的 salt。

column.mask.hash.SHA-256.with.salt.CzQMA0cB5K = inventory.orders.customerName, inventory.shipment.customerName

schema1.*:FULL,schema2.table2:NOTHING,schema2.table3:INDEX idx_name

isbn.type: io.debezium.test.IsbnConverter

isbn.schema.name: io.debezium.postgresql.type.Isbn

"snapshot.select.statement.overrides": "customer.orders",
"snapshot.select.statement.overrides.customer.orders": "SELECT * FROM [customers].[orders] WHERE delete_flag = 0 ORDER BY id DESC"