更改 Debezium 连接器使用的主题名称
Change topic name used by Debezium connector
我想使用 Debezium 连接器更改主题名称，因为我不希望主题以默认名称“server.schema.table”命名。
您可以使用各种Kafka Connect transforms来设置主题名称。
InsertField设置静态主题名ExtractField + ExtractTopic 用于使用一些 属性 的记录 RegexRouter 用于根据模式修改主题名称；例如，删除 server.schema. 前缀 - 你自己的
我想使用 Debezium 连接器更改主题名称，因为我不希望主题以默认名称“server.schema.table”命名。
您可以使用各种Kafka Connect transforms来设置主题名称。
InsertField设置静态主题名ExtractField+ExtractTopic用于使用一些 属性 的记录RegexRouter用于根据模式修改主题名称；例如，删除server.schema.前缀- 你自己的