5.5. 部署 Debezium MySQL 连接器

没有默认值 连接器的唯一名称。尝试再次使用相同的名称注册失败。所有 Kafka Connect 连接器都需要此属性。 connector.class 没有默认值 连接器的 Java 类的名称。始终为 MySQL 连接器指定 io.debezium.connector.mysql.MySqlConnector 。 tasks.max 应该为此连接器创建的最大任务数量。MySQL 连接器始终使用单个任务，因此不要使用这个值，因此始终可以接受默认值。 database.hostname 没有默认值 MySQL 数据库服务器的 IP 地址或主机名。 database.port MySQL 数据库服务器的整数端口号。 database.user 没有默认值 连接到 MySQL 数据库服务器时使用的 MySQL 用户的名称。 database.password 没有默认值 连接到 MySQL 数据库服务器时要使用的密码。 topic.prefix 没有默认值 为 Debezium 捕获更改的特定 MySQL 数据库服务器/集群提供命名空间的主题前缀。主题前缀应该在所有其他连接器中唯一，因为它用作接收此连接器发送的事件的所有 Kafka 主题名称的前缀。数据库服务器逻辑名称中只能使用字母数字字符、连字符、句点和下划线。

不要更改此属性的值。如果您更改了 name 值，重启后，而不是继续向原始主题发出事件，连接器会将后续事件发送到名称基于新值的主题。连接器也无法恢复其数据库架构历史记录主题。 database.server.id 没有默认值 此数据库客户端的数字 ID，必须在 MySQL 集群中所有当前运行的数据库进程之间唯一。此连接器将 MySQL 数据库集群加入为另一个服务器（使用此唯一 ID），以便读取 binlog。 database.include.list 可选的、以逗号分隔的正则表达式列表，与要捕获更改的数据库的名称匹配。连接器不会捕获任何名称不在 database.include.list 中的更改。默认情况下，连接器捕获所有数据库中的更改。
要匹配数据库的名称，Debebe 应用 您指定的正则表达式 。也就是说，指定的表达式与数据库的整个名称字符串匹配，它与数据库名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，不要设置 database.exclude.list 属性。 database.exclude.list 可选的、以逗号分隔的正则表达式列表，与您不想捕获更改的数据库名称匹配。连接器捕获名称不在 database.exclude.list 中的任何数据库中的更改。
要匹配数据库的名称，Debebe 应用 您指定的正则表达式 。也就是说，指定的表达式与数据库的整个名称字符串匹配，它与数据库名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，不要设置 database.include.list 属性。 table.include.list 可选的、以逗号分隔的正则表达式列表，与您要捕获更改的表的完全限定表标识符匹配。连接器不会捕获没有在 table.include.list 中包含的任何表中的更改。每个标识符的格式都是 databaseName 。 tableName 。默认情况下，连接器捕获捕获更改的每个数据库中的每个非系统表中的更改。
要匹配表的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与表的整个名称字符串匹配，它与表名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，不要设置 table.exclude.list 属性。 table.exclude.list 可选的、以逗号分隔的正则表达式列表，与您不想捕获更改的表的完全限定表标识符匹配。连接器捕获 table.exclude.list 中没有包含的任何更改。每个标识符的格式都是 databaseName 。 tableName 。
要匹配列的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与表的整个名称字符串匹配，它与表名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，不要设置 table.include.list 属性。 column.exclude.list 可选的、以逗号分隔的正则表达式列表，与列的完全限定名称匹配，以便从更改事件记录值中排除。列的完全限定域名格式为 databaseName 。 tableName . columnName 。
要匹配列的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与列的整个名称字符串匹配，它与列名称中可能存在的子字符串不匹配。如果您在配置中包含此属性，不要设置 column.include.list 属性。 column.include.list 可选的、以逗号分隔的正则表达式列表，与更改事件记录值中包含的列的完全限定名称匹配。列的完全限定域名格式为 databaseName 。 tableName . columnName 。
要匹配列的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与列的整个名称字符串匹配，它与列名称中可能存在的子字符串不匹配。
如果您在配置中包含此属性，请不要设置 column.exclude.list 属性。 column.truncate.to. length .chars 一个可选的、以逗号分隔的正则表达式列表，与基于字符的列的完全限定名称匹配。如果您要在一组列中超过属性名称中指定的字符数时，设置此属性。 将 length 设置为正整数值，例如 column.truncate.to.20.chars 。 列的完全限定域名会观察以下格式： databaseName . tableName . columnName 。要匹配列的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与列的整个名称字符串匹配；表达式不匹配列名称中可能存在的子字符串。 您可以在单个配置中指定多个长度不同的属性。 column.mask.with. length .chars 一个可选的、以逗号分隔的正则表达式列表，与基于字符的列的完全限定名称匹配。如果您希望连接器屏蔽一组列的值，例如，如果它们包含敏感数据，则设置此属性。将 length 设置为正整数，将指定列中的数据替换为属性名称中 长度 指定的星号(DSL)字符数。 将 length 设为 0 ( 零)将指定列中的数据替换为空字符串。 列的完全限定域名会观察以下格式： databaseName . tableName . columnName 。要匹配列的名称，Debebe 应用您指定的正则表达式。 也就是说，指定的表达式与列的整个名称字符串匹配；表达式不匹配列名称中可能存在的子字符串。 您可以在单个配置中指定多个长度不同的属性。 column.mask.hash. hashAlgorithm .with.salt. salt ; hash- hash.v2. hashAlgorithm .with.salt. salt 一个可选的、以逗号分隔的正则表达式列表，与基于字符的列的完全限定名称匹配。列的完全限定域名格式为 < databaseName>。< tableName & gt; . < columnName&gt ;。
要匹配 column Debezium 的名称，请应用您指定为 锚 正则表达式的正则表达式。也就是说，指定的表达式与列的整个名称字符串匹配；表达式不匹配列名称中可能存在的子字符串。在生成的更改事件记录中，指定列的值替换为 pseudonyms。
一个 pseudonym，它包括了通过应用指定的 hashAlgorithm 和 salt 的结果的哈希值。根据使用的 hash 功能，会维护引用完整性，而列值则替换为伪nyms。支持的哈希功能在 Java Cryptography 架构标准算法名称文档中的 MessageDigest 部分 进行了描述。

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

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

connect.keep.alive 指定是否应使用单独的线程来确保与 MySQL 服务器/集群的连接保持处于活动状态的布尔值。 converters 没有默认值 枚举连接器可以使用 的自定义转换器 实例的符号名称的逗号分隔列表。
例如， 布尔值 。
需要此属性才能使连接器使用自定义转换器。 对于您为连接器配置的每个转换器，还必须添加一个 .type 属性，它指定了实现转换器接口的类的完全限定域名。 .type 属性使用以下格式：
<converterSymbolicName> .type

boolean.type: io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter

boolean.selector=db1.table1.*, db1.table2.column1

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