abcCL opened a new issue #10299:
URL: https://github.com/apache/pulsar/issues/10299
**Describe the bug**
First I produce 1,000,000 messages into the topic and batch receive from it
, but not ack them.
After one or two batch receive , I get almost 250,000 messages , and later
the num of batch receive messages is 0.
**To Reproduce**
batch policy
```
consumer = client.newConsumer()
.topic(topic)
.subscriptionName(getRequired(JobPropKey.consumerGroup))
.subscriptionType(SubscriptionType.Shared)
.consumerName(DefaultValue.appName)
.negativeAckRedeliveryDelay(5, TimeUnit.SECONDS)
.receiverQueueSize(1000000)
.batchReceivePolicy(BatchReceivePolicy.builder()
.maxNumMessages(1000000)
.maxNumBytes(1024 * 1024 * 512)
.timeout(10000, TimeUnit.MILLISECONDS)
.build())
.subscribe();
```
**Expected behavior**
I just want to receive the messages
**Screenshots**
If applicable, add screenshots to help explain your problem.
**Desktop (please complete the following information):**
- OS: Linux Mac
--
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]
