mysql+debezium+kafka主题(未创建主题)

qnzebej0  于 2021-06-21  发布在  Mysql
关注(0)|答案(0)|浏览(216)

使用以下属性

name=mysql
connector.class=io.debezium.connector.mysql.MySqlConnector
database.hostname=localhost
database.port=3306
database.user=root
database.password=admin
database.server.id=42
database.server.name=mysql
database.history.kafka.topic=dbhistory.sys
database.history.kafka.bootstrap.servers=localhost:9092
include.schema.changes=true

加载方式

bin\windows\connect-standalone.bat config\connect-standalone.properties config\mysql.properties

创建的主题

dbhistory.sys,mysql

但当数据库发生任何变化时,都不会创建主题。我试过用mongo+debezium。工作正常。但mysql不行。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题