RocketMQ集群调试

开放端口

9876:NameServer端口
10909:VIP通道端口
10911:主Broker端口
10912:从Broker端口

10909是VIP通道对应的端口,在JAVA中的消费者对象或者是生产者对象中关闭VIP通道即可无需开放10909端口

使用如下方法

setVipChannelEnabled(false);

如果没有开放10909及10911端口,可能会报如下错误:

生产者发送消息

sendDefaultImpl call timeout

消费者未在线

MessageTrack [consumerGroup=xxxxxx, trackType=NOT_ONLINE, exceptionDesc=CODE:206 DESC:Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message]

双master双slave

配置文件修改三个参数

  • slave的brokerName和主的一样
  • brokerId要大于0
  • brokerRole这个值要变成SLAVE

查看进程

# ps -ef | grep namesrv
# ps -ef | grep broker
上一篇 rocketmq-console 部署采坑记录
下一篇 RocketMQ之Producer
目录
文章列表
1 Flutter Widget之FloatingActionButton
Flutter Widget之FloatingActionButton
2
Spring Boot 发布回滚
Spring Boot 发布回滚
3
Vuex状态监听mapState与普通的局部计算属性混合使用
Vuex状态监听mapState与普通的局部计算属性混合使用
4
Groovy代码示例 - groovy类与脚本
Groovy代码示例 - groovy类与脚本
5
Jenkins构建Android apk执行Shell配置
Jenkins构建Android apk执行Shell配置
最新评论
一位WordPress评论者
一位WordPress评论者
2月12日
您好,这是一条评论。若需要审核、编辑或删除评论,请访问仪表盘的评论界面。评论者头像来自 Gravatar。