【发布时间】:2020-06-05 07:35:37
【问题描述】:
寻找一种解决方法或方法来处理 Maxwell 或 Debezium kafka 中的场景以在模式名称包含 . 的 mysql 表上启用复制,我们已经能够成功地从怀疑 . 的其他模式复制表导致问题
【问题讨论】:
标签: mysql apache-kafka apache-kafka-connect debezium
寻找一种解决方法或方法来处理 Maxwell 或 Debezium kafka 中的场景以在模式名称包含 . 的 mysql 表上启用复制,我们已经能够成功地从怀疑 . 的其他模式复制表导致问题
【问题讨论】:
标签: mysql apache-kafka apache-kafka-connect debezium
从 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
【讨论】: