主题的路由

Debezium连接器发送的默认行为是每个更改事件记录到一个话开云体育官方注册网址题,他的名字叫的名称由数据库和表的名称的改变。开云体育电动老虎机换句话说,一个主题为一个物理表接收记录。当你想要一个主题来接收记录超过一个物理表,您必须配置Debezium连接器,重新路由记录到这个话题。开云体育官方注册网址

一个逻辑表是一种常见的用例路由记录多个物理表的一个主题。在一个逻辑表,有多个物理表都有相同的模式。例如,分片表有相同的模式。一个逻辑表可能由两个或两个以上的分片表:db_shard1.my_table和db_shard2.my_table。表在不同的碎片和身体不同的但他们联合起来,组成一个逻辑表。你可以重新改变事件纪录表的同一主题的碎片。

当Debezium开云体育官方注册网址 PostgreSQL连接器捕获一个分区表的变化,默认行为是改变事件记录为每个分区路由到一个不同的主题。排放记录从所有分区到一个主题,配置主题路由SMT。因为分区表中的每个关键是保证是独一无二的,配置key.enforce.uniqueness = false所以SMT不添加一个关键字段,以确保独特的钥匙。添加一个关键字段的默认行为。

路由更改事件记录多个物理表相同的主题,配置路由转换话题的卡夫卡Debezium连接器的连接配置。开云体育官方注册网址主题的配置路由SMT需要您指定正则表达式决定:

连接器配置在下面的示例主题路由SMT设置几个选项:

您可以定义自定义配置SMT谓词语句指定的表你想要转换的过程,还是不过程。谓词可能有用如果你配置SMT正则表达式相匹配的路由表,你不希望SMT改变一个特定的表相匹配的表达式。

De开云体育官方注册网址bezium更改事件键使用表列的表的主键。路由记录多个物理表的一个主题,事件键必须是唯一的在所有的表。然而,它是可能的每个物理表有一个主键,只表内是独一无二的。例如,中的一行myserver.mydb.customers_shard1表可能有相同的键值的行myserver.mydb.customers_shard2表。

确保每个事件关键是独一无二的整个表的更改事件记录去相同的话题,这个话题路由转换将一个字段插入更改事件的钥匙。默认情况下,插入的字段的名称__dbz__physicalTableIdentifier。插入的字段的值是默认目标主题名称。

如果你想,你可以配置路由转换话题不同的字段插入钥匙。要做到这一点,指定key.field.name选项,将其设置为一个字段名,不与现有的主键字段名称冲突。例如:

这个例子添加shard_id领域的关键结构路由记录。

如果你想调整关键的新字段的值,配置这两个选项:

例如:

在这个配置中,我们假设缺省目标主题名称是:

myserver.mydb.customers_shard1
myserver.mydb.customers_shard2
myserver.mydb.customers_shard3

转换使用捕获的值在第二组,碎片数量,关键的新字段的值。在这个例子中,将插入键字段的值1,2,或3。

如果你的表包含全局惟一键和你不需要改变的关键结构,你可以设置key.enforce.uniqueness选项假:

除了改变事件消息,Debezium连接器排放数据库变化发生时,连接器还散发出其他类型的消息,包括开云体育官方注册网址心跳消息,和元数据信息模式变化和事务。开云体育电动老虎机因为这些消息的结构不同于SMT的改变事件消息的结构设计过程,最好配置连接器有选择地应用SMT,这样流程只有预期的数据变化信息。

您可以使用下列方法之一来配置连接器应用SMT选择性:

下表描述了主题路由SMT配置选项。