2017-10-13 823 views
0

我正在使用Debezium插件来Kafka Connect来传输MySQL数据库更改。为什么Debezium会为所有表格创建主题,即使指定了table.whitelist

我已明确在

connector.properties

table.whitelist提到了我的白名单 = tripDriverMapping

database.tables = azuga.tripDriverMapping

enter image description here

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

+0

你可以发布你的整个连接器配置?另外,截图并不是一个很好的方式来分享主题列表,更好的是简单地输出'kafka-topics --zookeeper :2181 --list' –

+0

这实际上不应该发生;您是否在未列入白名单的表格的主题中看到任何消息? – Gunnar

回答

2

正确的配置是

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

database.whitlist可能是可选

相关问题