0
我正在使用Debezium插件来Kafka Connect来传输MySQL数据库更改。为什么Debezium会为所有表格创建主题,即使指定了table.whitelist
我已明确在
connector.properties
table.whitelist提到了我的白名单表 = tripDriverMapping
database.tables = azuga.tripDriverMapping
为什么Debezium会为数据库中的所有表创建主题?是否有任何解决方法可以避免创建所有这些不必要的主题,因为我将仅从一个主题中使用这些主题。
你可以发布你的整个连接器配置?另外,截图并不是一个很好的方式来分享主题列表,更好的是简单地输出'kafka-topics --zookeeper:2181 --list' –
这实际上不应该发生;您是否在未列入白名单的表格的主题中看到任何消息? – Gunnar