devinbost commented on issue #6054:
URL: https://github.com/apache/pulsar/issues/6054#issuecomment-818400418
I extracted this permit information from one of the brokers after enabling
debug mode:
> Apr 12 18:55:52 fab08 8f9131691776: 2021-04-13T00:55:52,441
[pulsar-io-25-64] DEBUG org.apache.pulsar.broker.service.ServerCnx -
[/10.20.69.29:55956] Received flow from consumer 0 permits: 500
> Apr 12 18:55:52 fab08 8f9131691776: 2021-04-13T00:55:52,441
[pulsar-io-25-64] DEBUG
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers
- [persistent://myTenant/myNamespace/topic-2 /
myTenant/myNamespace/function-2-Consumer{subscription=PersistentSubscription{topic=persistent://myTenant/myNamespace/topic-2,
name=myTenant/myNamespace/function-2}, consumerId=0, consumerName=c44ef,
address=/10.20.69.29:55956}] Trigger new read after receiving flow control
message with permits 919
> Apr 12 18:55:52 fab08 8f9131691776: 2021-04-13T00:55:52,442
[pulsar-io-25-64] DEBUG org.apache.pulsar.broker.service.Consumer -
[persistent://myTenant/myNamespace/topic-2-PersistentSubscription{topic=persistent://myTenant/myNamespace/topic-2,
name=myTenant/myNamespace/function-2}] Added more flow control message permits
500 (old was: 419), blocked = false
> Apr 12 18:56:22 fab08 8f9131691776: 2021-04-13T00:56:22,301
[pulsar-io-25-64] DEBUG org.apache.pulsar.broker.service.Consumer -
[persistent://myTenant/myNamespace/topic-2-PersistentSubscription{topic=persistent://myTenant/myNamespace/topic-2,
name=myTenant/myNamespace/function-2}] Added more flow control message permits
500 (old was: -14), blocked = false
> Apr 12 18:56:52 fab08 8f9131691776: 2021-04-13T00:56:52,502
[bookkeeper-ml-workers-OrderedExecutor-1-0] DEBUG
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers
- [persistent://feeds/myTenant/topic-1-partition-1 /
myTenant/myNamespace/function-1] No consumers found with available permits,
storing 29 positions for later replay
> Apr 12 19:00:52 fab08 8f9131691776: 2021-04-13T01:00:52,488
[bookkeeper-ml-workers-OrderedExecutor-7-0] DEBUG
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers
- [persistent://myTenant/myNamespace/topic-2 /
myTenant/myNamespace/function-2] No consumers found with available permits,
storing 67 positions for later replay
--
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:
us...@infra.apache.org
