布署环境:
两个namesrv, 4个broker,两主两备
broker配置:
brokerClusterName=rbcycle_wan
brokerName=broker-a
brokerId=0
brokerRole=MASTER
namesrvAddr=xxxxxxxx
brokerIP1=xxxxxxxx
brokerIP2=xxxxxxxx
listenPort=10911
deleteWhen=04
fileReservedTime=48
flushDiskType=ASYNC_FLUSH
rocketmqHome=/opt/rocketmq/
storePathRootDir=/opt/rocketmq/data/
storePathCommitLog=/opt/rocketmq/data/commitlog/
storePathConsumerQueue=/opt/rocketmq/data/consumequeue/
autoCreateTopicEnable=false
autoCreateSubscriptionGroup=false
sendMessageThreadPoolNums=256
pullMessageThreadPoolNums=256
#64m
maxMessageSize=67108864
#64m
maxTransferBytesOnMessageInMemory=67108864
maxTransferCountOnMessageInMemory=1000
maxTransferBytesOnMessageInDisk=67108864
maxTransferCountOnMessageInDisk=100
accessMessageInMemoryMaxRatio=40
messageIndexEnable=false
maxMsgsNumBatch=512
serverChannelMaxIdleTimeSeconds=300 #默认120
clientChannelMaxIdleTimeSeconds=300
rocketmq的版本:4.2.0
日志:
{msgId=AC13384C00002A9F00000421194DEA2E,queueId=12,storeSize=1620,sysFlag=0,queueOffset=205761790,commitLogOffset=4540204968494,preparedTransactionOffset=0,bornTimestamp=1540292849801,bornHost=172.16.204.127:2748,storeHost=xxx.xxx.xx.xx:40746,storeTimestamp=1540292849807,reconsumeTimes=0,bodyCRC=1870354735,Message={m_topic=topic-xxxxx-xxxx,m_flag=0,properties={CONTENT_ENCODING=gzip,KEYS=KEY,MAX_OFFSET=205761791,MIN_OFFSET=200911434,TAGS=*,WAIT=true},m_bodyLen=1466}}|
message len|1466|
期待您的回复。
Best wish
Will.
On 2018/10/23 02:22:26, Shannon <[email protected]> wrote:
>
>
>
> Hello,
> 日志和系统环境相关的信息提供一下。
> 另外,支持动态库的CPP版本和 C-style的API很快就会发布,可以用起来了。
>
>
>
>
>
>
>
>
> 在 2018-10-22 10:57:08,"[email protected]"
> <[email protected]> 写道:
> >Hi.
> >
> > rocketmq的大大们,最近生产上rocketmq使用遇到了一个比较奇怪的问题,消费端收到了生产端发给rocketmbroker的心跳消费,并且是作为消息的body部份被消费端收到了。收到的内容大致如下:
> >{"code":34,"language":"CPP","version":79,"opaque":1543839,"flag":0,"remark":"","extFields":{}}{"clientID":"xx.xxx.xxx.xxx@0C3CF166-C66D-11E8-B98A-F8403C407001","consumerDataSet":[],"producerDataSet":[{"groupName":"CLIENT_INNER_PRODUCER"},{"groupName":"pg-xxxx-xxxx"}]}
> >(ip和group是我改的),这个不是必现的,是偶尔出现,且概率比较小,定位了一下也没发现个所以然,想请教一下各位大大们生产中有没有遇到过类似的问题。
> >
> >thanx
> >Best wish.
> > will.
>