【发布时间】：2021-10-11 06:44:07
【问题描述】：
我想使用 Debezium 连接器更改主题名称，因为我不想使用默认名称“server.schema.table”来命名主题。
【问题讨论】：
标签： apache-kafka apache-kafka-connect debezium
【发布时间】：2021-10-11 06:44:07
【问题描述】：
您可以使用各种Kafka Connect transforms 来设置主题名称。
-
InsertField设置静态主题名称 -
ExtractField+ExtractTopic用于使用记录的某些属性 -
RegexRouter用于根据模式修改主题名称；例如，删除server.schema.前缀 - 你自己的一个
【讨论】：
-
我正在使用 ksql，我应该在连接器创建中添加哪些代码行以使 sm2.ingestion.surf.db.TableName 用作主题创建的默认名称？
-
能否在您的问题中显示您的连接器配置？ Ksql 嵌入了 Connect。
transforms是连接器属性。 InsertField 类型将设置静态主题名称...浏览示例链接 -
或者，如果您尝试在数据库名称前加上
sm2.ingestion.surf前缀，请使用 RegexRouter