jiqingsuiyue opened a new issue #2945:
URL: https://github.com/apache/rocketmq/issues/2945


   where I send message,the rocketmq report broker busy or system busy
   E.g:
     CODE: 2  DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a 
while, period in queue: 200ms, size of queue: 12 
   my rocketmq config:
   brokerName=Lifekh_Broker1
   brokerClusterName=Lifekh_Cluster
   brokerId=0
   autoCreateTopicEnable=true
   autoCreateSubscriptionGroup=true
   rejectTransactionMessage=false
   fetchNamesrvAddrByAddressServer=false
   storePathRootDir=/data/rocketmq_lifekh/store
   storePathCommitLog=/data/rocketmq_lifekh/store/commitlog
   storePathConsumeQueue=/data/rocketmq_lifekh/store/consumequeue
   storePathIndex=/data/rocketmq_lifekh/store/index
   storeCheckpoint=/data/rocketmq_lifekh/store/checkpoint
   abortFile=/data/rocketmq_lifekh/store/abort
   flushIntervalCommitLog=1000
   flushCommitLogTimed=false
   deleteWhen=04
   fileReservedTime=72
   mapedFileSizeCommitLog=1073741824
   maxMessageSize=65536
   mapedFileSizeConsumeQueue=300000
   maxTransferBytesOnMessageInMemory=262144
   maxTransferCountOnMessageInMemory=32
   maxTransferBytesOnMessageInDisk=65536
   maxTransferCountOnMessageInDisk=8
   accessMessageInMemoryMaxRatio=40
   messageIndexEnable=true
   messageIndexSafe=false
   haMasterAddress=
   brokerRole=ASYNC_MASTER
   flushDiskType=ASYNC_FLUSH
   cleanFileForciblyEnable=true
   #发消息线程池数量
   sendMessageThreadPoolNums=8
   #发送消息是否使用可重入锁
   useReentrantLockWhenPutMessage=true
   
   rocketmq version: 4.5
   Can anyone help?thank you!


-- 
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:
[email protected]


Reply via email to