更改 Debezium 连接器使用的主题名称

Posted 2023-03-23

【中文标题】更改 Debezium 连接器使用的主题名称

【英文标题】：Change topic name used by Debezium connector

【发布时间】：2021-10-11 06:44:07

【问题描述】：

我想使用 Debezium 连接器更改主题名称，因为我不想使用默认名称“server.schema.table”来命名主题。

【参考方案1】：

您可以使用各种Kafka Connect transforms 来设置主题名称。

InsertField设置静态主题名称 ExtractField + ExtractTopic 用于使用记录的某些属性 RegexRouter 用于根据模式修改主题名称；例如，删除 server.schema. 前缀 你自己的一个

【讨论】：

我正在使用 ksql，我应该在连接器创建中添加哪些代码行以使 sm2.ingestion.surf.db.TableName 用作主题创建的默认名称？

能否在您的问题中显示您的连接器配置？ Ksql 嵌入了 Connect。 transforms 是连接器属性。 InsertField 类型将设置静态主题名称...浏览示例链接

或者，如果您尝试在数据库名称前加上 sm2.ingestion.surf 前缀，请使用 RegexRouter