michalcukierman commented on issue #21082:
URL: https://github.com/apache/pulsar/issues/21082#issuecomment-1698836870
I can reproduce the issue on my system now. Using build from master from
Monday.
I have a topic using `3` partitions with `1100013` messages.
The client and the consumer:
```java
client = PulsarClient.builder()
.serviceUrl(this.pulsarBrokerUrl)
.build();
Consumer<PublicationEvent> consumer =
client.newConsumer(Schema.PROTOBUF(PublicationEvent.class))
.topic(sourceTopic)
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
.subscriptionName(subscriptionName)
.subscriptionType(SubscriptionType.Shared)
.receiverQueueSize(8)
.ackTimeout(ackTimeout, TimeUnit.SECONDS)
.subscribe();
```
was able to retrieve `53527` messages and stopped. I see in the log files
the entry:
```bash
[ConsumerBase{subscription='publications-router', consumerName='8c650',
topic='persistent://websight/dxp/monolog'}] 1 messages will be re-delivered
```
<img width="2792" alt="Screenshot 2023-08-30 at 10 52 03"
src="https://github.com/apache/pulsar/assets/4356553/9062ace4-a6d0-4246-b543-48be5aa14998";>
I can read the messages using pulsar-perf with exclusive consumer.
--
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]
