最近学习RocketMQ遇到的一些问题
2020-06-12 本文已影响0人
Leo_5cdb
启动报错
若Rocket服务器未启动端口10909,则报connect to <> failed。
目前这种写法Rocket默认开启了VIP通道,VIP通道端口为10911-2=10909。
原因是用了阿里3.5.9,这个版本如果没有开启VIP通道,那么需要手动设置
producer.setVipChannelEnabled(false);
具体参考:
https://www.cnblogs.com/zhjh256/p/6944431.html
由于服务器使用的是阿里3.2.6版本,本地使用的jar包是3.6.2.Final版本,发现重启Consumer的时候会反复的读取历史数据,回传了SUCCESS也不行,在网上找资料说是
jar版本和服务器版本不匹配,尝试用3.5.9一下版本 报了一个netty的NIO问题,尝试本地使用3.5.9版本的jar可以解决此问题。