Kafka connect(Debezium mysql连接器)只监听table.include.list中的特定表

Question

我使用debezium连接器读取数据库中写入的数据，然后将其发送给kafka，由kafka消费者使用。我在table.include.list中指定了三个表，但它只监听第一个表中的更改。以下是我在kafka连接中使用的配置：

connector.class=io.debezium.connector.mysql.MySqlConnector
database.user=root
topic.creation.default.partitions=3
database.server.id=184092
tasks.max=1
database.history.kafka.bootstrap.servers=kafka:9092
database.history.kafka.topic=history_dev2.test
database.server.name=test_name
database.port=3306
database.hostname=localhost
database.password=root
topic.creation.default.replication.factor=1
table.include.list=test.t1,test.t2,test.t3
database.include.list=test

Answer 1

您必须在表.include.list属性中添加Regex

Ex。

table.include.list=^(test.)((t1)|(t2)|(t3))$