我设置了这个 canal.instance.filter.regex=db_shopdog_test.deli_order 但是kafka里面解析不到schema名和表名
原提问者GitHub用户ZSH9053
根据提供的信息,可以看出问题可能出在以下几个方面:
1、Canal的filter规则配置是否正确:检查配置文件中的 canal.instance.filter.regex 是否正确设置为 db_shopdog_test.deli_order,且没有其他的过滤规则覆盖掉了这个规则。
2、Canal服务连接MySQL是否正常:检查Canal服务是否正确连接到MySQL,并且同步了该表的数据。可以通过查看Canal日志文件来确定是否有错误发生。
3、Kafka的消息格式是否正确:检查消息内容是否包含了schema名和表名。可以通过查看消息的原始内容来确定消息格式是否正确。
4、消费者程序是否正确解析消息:检查消费者程序是否正确解析了Kafka消息中的schema名和表名。可以通过查看消费者程序的代码来确定是否有问题。
如果以上都没有问题,可以尝试使用Canal提供的JDBC方式来消费数据,看看是否能够正确获取到schema名和表名。如果仍然存在问题,可以考虑升级Canal和Kafka版本,或者咨询相关技术支持。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。