在maxwell或debezium kafka中寻找解决方案或方法来处理场景，以便在模式名包含 . ，我们已经能够成功地从其他怀疑 . 是问题的根源
.
xtfmy6hx1#
根据文件，从debezium0.3开始，debeziummysql连接器确保所有kafka connect模式名都是有效的avro模式名。这意味着逻辑服务器名称必须以拉丁字母或下划线开头（例如，[a-z，a-z，304;]），逻辑服务器名称中的其余字符以及数据库和表名称中的所有字符必须是拉丁字母、数字或下划线（例如，[a-z，a-z，0-9，304;]）。否则，所有无效字符将自动替换为下划线字符。当逻辑服务器名称、数据库名称和表名称包含其他字符，并且表全名之间的唯一区别字符无效，因此被下划线替换时，这可能导致架构名称中出现意外冲突因此，如果模式的名称是 .xyz 你想复制这个表 w ```table.whitelist= abc.xyz.w
.xyz
w
debezium将尝试读取表 `.xyz_w`
1条答案
按热度按时间xtfmy6hx1#
根据文件，
从debezium0.3开始，debeziummysql连接器确保所有kafka connect模式名都是有效的avro模式名。这意味着逻辑服务器名称必须以拉丁字母或下划线开头（例如，[a-z，a-z，304;]），逻辑服务器名称中的其余字符以及数据库和表名称中的所有字符必须是拉丁字母、数字或下划线（例如，[a-z，a-z，0-9，304;]）。否则，所有无效字符将自动替换为下划线字符。
当逻辑服务器名称、数据库名称和表名称包含其他字符，并且表全名之间的唯一区别字符无效，因此被下划线替换时，这可能导致架构名称中出现意外冲突
因此，如果模式的名称是
.xyz你想复制这个表w```table.whitelist= abc.xyz.w