最近学习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可以解决此问题。

上一篇下一篇

猜你喜欢

热点阅读