linqh1 opened a new issue, #5498:
URL: https://github.com/apache/rocketmq/issues/5498
**BUG REPORT**
1. Please describe the issue you observed:
- What did you do (The steps to reproduce)?
```
DefaultLitePullConsumer pullConsumer = new
DefaultLitePullConsumer("testGroup");
pullConsumer.setNamesrvAddr(consumerProperties.getNameserver());
pullConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
pullConsumer.setPullBatchSize(20);
pullConsumer.setPullThreadNums(10);
pullConsumer.setAutoCommit(true);
pullConsumer.subscribe(consumerProperties.getTopic(),
SubscriptionData.SUB_ALL);
pullConsumer.start();
while(true) {
List<MessageExt> msgs = pullConsumer.poll();
}
```
with the above setings, `poll `method **always return 1 message**;
- What is expected to see?
pullConsumer.poll() return more than 1 messaage.
- What did you see instead?
When msgs is not empty, its size() is alway1
2. Please tell us about your environment:
RocketMQ version: 4.6.1
jar version: 4.6.1
4. Other information (e.g. detailed explanation, logs, related issues,
suggestions on how to fix, etc):
I was using `DefaultMQPushConsumer` to consume message with group name:
`testGroup`
Today I change to use `DefaultLitePullConsumer` to consume message with same
group name(`testGroup`), and then I run into this problem.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
