MySQL Debezium连接器架构更改主题

编程问答 2022-08-15

问题描述

我正在尝试使用here中所述的配置来构建Debezium MysqL Kafka Connect。在我的本地Kafka设置上，auto.create.topics.enable设置为true。

这是我的连接器JSON配置的样子：-

{
    "name": "MysqLConnector","connector.class": "io.debezium.connector.MysqL.MysqLConnector","tasks.max": 1,"database.allowPublicKeyRetrieval": "true","database.user": "sambhav","database.server.id": "654","database.history.kafka.bootstrap.servers": "192.168.1.4:9092","database.history.kafka.topic": "schema-changes.inventory",**
    "database.server.name": "dbserver1",*
    "database.port": "3306","database.hostname": "192.168.1.4","database.password": "password","database.whitelist": "samsoft"
}

部署连接器后，我看到与表的Kafka主题一起创建了另外两个主题，它们的名称分别是在database.server.name和database.history.kafka.topic配置中指定的值。

连接器文档中提到

如果您选择使用架构更改事件，请使用架构更改主题，而不使用数据库历史记录主题。

这是什么意思？

问题

一旦我尝试在auto.create.topics.enable设置为false的环境中部署相同的设置，连接器任务将找不到名为dbserver1的主题，因为我只创建了一个主题{{ 1}}（为schema-changes.inventory配置而配置。

  • 由database.history.kafka.topic和database.server.name设置创建的2个kafka主题的区别和目的是什么？这两个设置都是必需的。
  • 如何解决此问题？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka-connectdebeziummysql