带有 column.include.list 的 Debezium 连接器

Posted 2023-03-23

【中文标题】带有 column.include.list 的 Debezium 连接器

【英文标题】：Debezium connector with column.include.list

【发布时间】：2021-12-28 12:55:40

【问题描述】：

如果我需要对一个表的一部分和另一个表的完整数据进行快照，如何在 Debezium 连接器配置中组合 table.include.list 和 column.include.list？

连接器配置示例：

"table.include.list":"schema.table1, schema.table2",
"column.include.list":"schema.table1.col1, schema.table1.col2"

有了这个，我得到了 kafka 中 table1 的所有列。

只管理如何使用不同的连接器来做到这一点。

我想使用一个连接器获取 table2 中的所有列和 table1 中的 2 列，可以吗？

【参考方案1】：

这应该可行：

"table.include.list":"schema\.table1,schema\.table2",
"column.include.list":"schema\.table1\.col1|col2,schema\.table2\..*"

【讨论】：

谢谢！为我工作。