【问题标题】:Maxwell and Debizium: Unable to replicate tables from mysql schema contains"." eg: `abc.xyz`.table_nameMaxwell 和 Debizium:无法从 mysql 架构复制表包含“。”例如:`abc.xyz`.table_name
【发布时间】:2020-06-05 07:35:37
【问题描述】:

寻找一种解决方法或方法来处理 Maxwell 或 Debezium kafka 中的场景以在模式名称包含 . 的 mysql 表上启用复制,我们已经能够成功地从怀疑 . 的其他模式复制表导致问题

【问题讨论】:

    标签: mysql apache-kafka apache-kafka-connect debezium


    【解决方案1】:

    根据documentation

    从 Debezium 0.3 开始,Debezium MySQL 连接器可确保所有 Kafka Connect 架构名称是有效的 Avro 架构名称。 这意味着 逻辑服务器名称必须以拉丁字母或 下划线(例如 [a-z,A-Z,_])和 逻辑服务器名称以及数据库和表名称中的所有字符 必须是拉丁字母、数字或下划线(例如, [a-z,A-Z,0-9,_])。如果不是,那么所有无效字符都会 自动替换为下划线字符

    当 逻辑服务器名称、数据库名称和表名称包含其他 字符,以及表满之间的唯一区别字符 名称无效,因此替换为下划线

    因此,如果您的架构名称是 abc.xyz 并且您想要复制表 w

    table.whitelist= abc.xyz.w
    

    Debezium 将尝试读取表 abc.xyz_w

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2011-01-25
      • 2021-01-08
      • 1970-01-01
      相关资源
      最近更新 更多