2

我正在使用 Kafka Connect 的 Debezium 插件来流式传输 MySQL 数据库更改。

我在_

连接器属性

table.whitelist=tripDriverMapping

database.tables=azuga.tripDriverMapping

在此处输入图像描述

为什么 Debezium 为数据库中的所有表创建主题？是否有任何解决方法可以避免创建所有这些不必要的主题，因为我将只使用一个主题。

4

1 回答 1

2

连接器的正确配置是：

database.whitelist=azuga
table.whitelist=azuga.tripDriverMapping

database.whitelist可能是可选的

于 2017-11-21T15:31:10.617 回答