You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2019/08/16 07:28:48 UTC
[GitHub] [rocketmq] sycoral opened a new issue #1391: ReputMessageService -
[BUG]logic queue order maybe wrong
sycoral opened a new issue #1391: ReputMessageService - [BUG]logic queue order maybe wrong
URL: https://github.com/apache/rocketmq/issues/1391
**1、测试场景：**
使用的rocketmq4.5.0版本，双主双从模式，异步刷盘/异步复制，用benchmark进行压测
1）发送性能压测，sh producer.sh -w 50 -k true -s 1024 -n 172.16.0.116:9876；
2）172.16.0.116/172.16.0.117互为主从，同时nameserver也在116与117启动两个；
**2、发现的问题：**
`WARN ReputMessageService - [BUG]logic queue order maybe wrong, expectLogicOffset: 22720 currentLogicOffset: 10660 Topic: BenchmarkTest QID: 246 Diff: 12060`
每次重新清空重新测试，都会出现，且是大量出现。
3、附配置如下，broker-a与broker-b，配置一致，下面只列broker-a的配置：
1）主配置
```
brokerClusterName=rocketmq-xw
brokerName=broker-a
brokerId=0
namesrvAddr=172.16.0.116:9876;172.16.0.117:9876
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
enablePropertyFilter = true
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/home/rocketMQ/rocketmq-4.5.0/store
#commitLog 存储路径
storePathCommitLog=/home/rocketMQ/rocketmq-4.5.0/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketMQ/rocketmq-4.5.0/store/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketMQ/rocketmq-4.5.0/store/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketMQ/rocketmq-4.5.0/store/checkpoint
#abort 文件存储路径
abortFile=/home/rocketMQ/rocketmq-4.5.0/store/abort
# 限制的消息大小 改为64M
maxMessageSize=67108864
# 同步超时时间 默认5s
# syncFlushTimeout=30
# 清除发送线程池任务队列的等待时间
waitTimeMillsInSendQueue=500
```
2）从配置
```
brokerClusterName=rocketmq-xw
brokerName=broker-a
brokerId=1
namesrvAddr=172.16.0.116:9876;172.16.0.117:9876
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
listenPort = 11911
enablePropertyFilter = true
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/home/rocketMQ/rocketmq-4.5.0/store-s
#commitLog 存储路径
storePathCommitLog=/home/rocketMQ/rocketmq-4.5.0/store-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/home/rocketMQ/rocketmq-4.5.0/store-s/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketMQ/rocketmq-4.5.0/store-s/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketMQ/rocketmq-4.5.0/store-s/checkpoint
#abort 文件存储路径
abortFile=/home/rocketMQ/rocketmq-4.5.0/store-s/abort
# 限制的消息大小 改为64M
maxMessageSize=67108864
# 同步超时时间 默认5s
syncFlushTimeout=30
# 清除发送线程池任务队列的等待时间
waitTimeMillsInSendQueue=500
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services