GitHub user ragaur-tibco edited a discussion: How to validate chunking in
consumer side
How can we validate or any use-case to check chunking is working in consumer
side
```
ConsumerBuilder<byte[]> consumerBuilder = client.newConsumer()
.topic("chunkTopic")
.subscriptionName("")
.maxPendingChunkedMessage(2)
.autoAckOldestChunkedMessageOnQueueFull(true)
.expireTimeOfIncompleteChunkedMessage(60000, TimeUnit.MILLISECONDS)
.subscriptionType("Shared");
Consumer consumer= consumerBuilder.subscribe();
```
want to know if there is any use-case or any debug logs from pulsar side to
check and validate chunking parameters maxPendingChunkedMessage,
autoAckOldestChunkedMessageOnQueueFull and expireTimeOfIncompleteChunkedMessage
CC: @lhotari
GitHub link: https://github.com/apache/pulsar/discussions/22491
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
