能启动成功,并且日志能看到已经找到了mysql binlog日志,但是kafka中无任何数据,而且,我故意把kafka的连接地址写错,日志也不会报kafka连接不上的错误,导致我没办法判断是我哪里出问题了,有人遇到过相同的问题么 instance.properties配置如下:
用的1.1.5 SNAPSHOT 版本的
原提问者GitHub用户2hang5ong
解决了,我是因为在canal.properties的canal.serverMode = kafka(1.5以下的版本默认是tcp,应该改成kafka) 这个值没改过来。注意,这个值在配置文件是有的,直接改就行,如果写了两次,后面的会覆盖前面的
原回答者GitHub用户2hang5ong
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。