graceon opened a new issue #11850:
URL: https://github.com/apache/pulsar/issues/11850
My Code
```
consumerListener = new ConsumerListener(name,processTime);
PulsarClient pulsarClient = PulsarClient.builder()
.serviceUrl("pulsar://192.168.184.131:6650")
.build();
consumer = pulsarClient.newConsumer()
.receiverQueueSize(0)
.topic("my_topic")
.subscriptionName("my_subscription")
.subscriptionType(SubscriptionType.Shared)
.subscribe();
```
debug it run into
```
# ZeroQueueConsumerImpl.class
void receiveIndividualMessagesFromBatch(MessageMetadata msgMetadata, int
redeliveryCount, List<Long> ackSet, ByteBuf uncompressedPayload, MessageIdData
messageId, ClientCnx cnx) {
log.warn("Closing consumer [{}]-[{}] due to unsupported received
batch-message with zero receiver queue size", this.subscription,
this.consumerName);
this.closeAsync().handle((ok, e) -> {
this.notifyPendingReceivedCallback((Message)null, new
InvalidMessageException(String.format("Unsupported Batch message with 0 size
receiver queue for [%s]-[%s] ", this.subscription, this.consumerName)));
return null;
});
}
```
i can receive messages when I use .receiverQueueSize(1)
i can not receive messages when I use .receiverQueueSize(0)
--
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]
