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();
```
As mentioned in pulsar documentation
**maxPendingChunkedMessage** = We can limit the maximum number of chunked
messages a consumer maintains concurrently by configuring the
maxPendingChunkedMessage parameter.
**autoAckOldestChunkedMessageOnQueueFull** = When @maxPendingChunkedMessage
threshold provided and the consumer reaches this threshold, it drops the
outstanding unchunked-messages by silently acknowledging if
autoAckOldestChunkedMessageOnQueueFull is true
**expireTimeOfIncompleteChunkedMessage** = If the producer fails to publish all
the chunks of a message, then the consumer can expire incomplete chunks if the
consumer doesn't receive all chunks during the expiration period
But 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
if I set the **maxPendingChunkedMessage**=2 and enable
**autoAckOldestChunkedMessageOnQueueFull** in consumer side, and send message
from producer of size 1000bytes and configure the max chunk size to 10 bytes
now how to check and validate or any debug logs for the
maxPendingChunkedMessage, autoAckOldestChunkedMessageOnQueueFull and
maxPendingChunkedMessage
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]
