【问题标题】:Debezium connector with column.include.list带有 column.include.list 的 Debezium 连接器
【发布时间】: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 列,可以吗?

【问题讨论】:

    标签: database apache-kafka stream debezium


    【解决方案1】:

    这应该可行:

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

    【讨论】:

    • 谢谢!为我工作。
    猜你喜欢
    • 2021-05-03
    • 2019-07-22
    • 2021-09-03
    • 2020-09-22
    • 2021-07-24
    • 2019-10-20
    • 2019-10-18
    • 2021-02-05
    • 2020-04-10
    相关资源
    最近更新 更多