我使用的是Debezium连接器，用于带有Kaffa的MySQL。所以我的模式更改和数据更改都进入了卡夫卡topcs。
我试着看看是否可以在没有人工干预的情况下实现以下行为。
我希望只有一个表作为snapshot.mode=initial快照的一部分。然后，我希望为正在进行的疾病控制与预防中心监测多个表格。
https://debezium.io/documentation/reference/stable/connectors/mysql.html似乎列出了快照表和cdc表的单独选项，所以我假设在连接器配置中可以实现以下内容：
...
"table.include.list": "api.table1, api.table2",
"snapshot.include.collection.list": "api.table1",
...
表1的快照完成，然后表1的CDC更改被拾取。我的kaffaschema-changes主题还显示了表1的模式。
然而，当我对表2中的数据进行更改时，我会得到Kafka连接器错误：
Caused by: io.debezium.DebeziumException: Encountered change event for table api.table2 whose schema isn't known to this connector
这种行为得到支持吗？还是我需要分步骤手动执行？
谢谢你的建议。
我也在debezium@googlegroups.com名单，并被善意地告知这是一个已知的问题。从那时到现在，已经发布了一个修复程序。非常感谢debezium团队！：(
https://issues.redhat.com/browse/DBZ-3952