rocketmq icon indicating copy to clipboard operation
rocketmq copied to clipboard

[Bugs]auto-bach cause some bugs

Open zhiliatom opened this issue 1 year ago • 7 comments

Before Creating the Bug Report

  • [X] I found a bug, not just asking a question, which should be created in GitHub Discussions.

  • [X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

  • [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

centos7

RocketMQ version

latest

JDK Version

jdk1.8

Describe the Bug

producer.setAutobatch(true) and send some inner-batch message, will cause some strange things

  1. query messge by msgid can't decode message body image
  2. when consume batch-message, and one of batch consume failed, will not reconsume

Steps to Reproduce

as below "testbatch":{ "attributes":{ "queue.type":"BatchCQ" }, "order":false, "perm":6, "readQueueNums":8, "topicFilterType":"SINGLE_TAG", "topicName":"testbatch", "topicSysFlag":0, "writeQueueNums":8 },

What Did You Expect to See?

as below

What Did You See Instead?

as below

Additional Context

No response

zhiliatom avatar Jan 19 '24 01:01 zhiliatom

PTAL @guyinyou

RongtongJin avatar Jan 19 '24 02:01 RongtongJin

Is this topic of batchConsumeQueue type?

guyinyou avatar Jan 19 '24 02:01 guyinyou

Is this topic of batchConsumeQueue type?

yes

zhiliatom avatar Jan 19 '24 02:01 zhiliatom

A msgId in batchConsumerQueue corresponds to an entire batch. If you want to maintain the same semantics as before, use an normal topic.

guyinyou avatar Jan 19 '24 02:01 guyinyou

A msgId in batchConsumerQueue corresponds to an entire batch. If you want to maintain the same semantics as before, use an normal topic.

When consume one of batch fail, will not even reconsume, sound unreasonable。

zhiliatom avatar Jan 19 '24 03:01 zhiliatom

What version that consumer?

guyinyou avatar Jan 19 '24 03:01 guyinyou

can you show your producer and consumer code, and their client version pls

francisoliverlee avatar Jan 21 '24 08:01 francisoliverlee