BewareMyPower commented on PR #15220:
URL: https://github.com/apache/pulsar/pull/15220#issuecomment-1103441676
The cpp tests uses an anonymous user role for tests.
```properties
anonymousUserRole=anonymous
```
The error logs are
```
2022-04-20T11:39:54,864+0800 [metadata-store-16-1] WARN
org.apache.pulsar.broker.authorization.AuthorizationService - Consumer-client
with Role - anonymous failed to get permissions for topic -
persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-2.
null
2022-04-20T11:39:54,867+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.ServerCnx - Closed connection from
/127.0.0.1:53830
2022-04-20T11:39:54,868+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-0,
name=sub}, consumerId=0, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
2022-04-20T11:39:54,869+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-3,
name=sub}, consumerId=3, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
2022-04-20T11:39:54,873+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-4,
name=sub}, consumerId=4, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
2022-04-20T11:39:54,873+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-2,
name=sub}, consumerId=2, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
2022-04-20T11:39:54,883+0800 [pulsar-io-15-12] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-1,
name=sub}, consumerId=1, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
2022-04-20T11:39:54,864+0800 [metadata-store-16-1] WARN
org.apache.pulsar.broker.service.Consumer - [anonymous] Get unexpected error
while autorizing
[persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-2]
null
java.util.concurrent.TimeoutException: null
at
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
~[?:?]
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021) ~[?:?]
at
org.apache.pulsar.broker.authorization.AuthorizationService.canConsume(AuthorizationService.java:247)
~[pulsar-broker-common.jar:2.9.2]
at
org.apache.pulsar.broker.service.Consumer.checkPermissions(Consumer.java:772)
~[pulsar-broker.jar:2.9.2]
at
java.util.concurrent.CopyOnWriteArrayList.forEach(CopyOnWriteArrayList.java:803)
~[?:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$onPoliciesUpdate$108(PersistentTopic.java:2464)
~[pulsar-broker.jar:2.9.2]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:413)
~[pulsar-common.jar:2.9.2]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:185)
~[pulsar-common.jar:2.9.2]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.onPoliciesUpdate(PersistentTopic.java:2463)
~[pulsar-broker.jar:2.9.2]
at
org.apache.pulsar.broker.service.BrokerService.lambda$handlePoliciesUpdates$90(BrokerService.java:1897)
~[pulsar-broker.jar:2.9.2]
at java.util.Optional.ifPresent(Optional.java:183) ~[?:?]
at
org.apache.pulsar.broker.service.BrokerService.lambda$handlePoliciesUpdates$91(BrokerService.java:1897)
~[pulsar-broker.jar:2.9.2]
at
java.util.concurrent.CompletableFuture.uniAcceptNow(CompletableFuture.java:753)
~[?:?]
at
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:731)
~[?:?]
at
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2108)
~[?:?]
at
org.apache.pulsar.broker.service.BrokerService.lambda$handlePoliciesUpdates$92(BrokerService.java:1892)
~[pulsar-broker.jar:2.9.2]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:413)
~[pulsar-common.jar:2.9.2]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:185)
~[pulsar-common.jar:2.9.2]
at
org.apache.pulsar.broker.service.BrokerService.lambda$handlePoliciesUpdates$93(BrokerService.java:1888)
~[pulsar-broker.jar:2.9.2]
at
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:714)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
~[?:?]
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$get$7(ZKMetadataStore.java:139)
~[pulsar-metadata.jar:2.9.2]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.74.Final.jar:4.1.74.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
2022-04-20T11:39:54,884+0800 [metadata-store-16-1] INFO
org.apache.pulsar.broker.service.Consumer - [anonymous] is not allowed to
consume from topic
[persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-2]
anymore
2022-04-20T11:39:54,884+0800 [metadata-store-16-1] INFO
org.apache.pulsar.broker.service.Consumer - Disconnecting consumer:
Consumer{subscription=PersistentSubscription{topic=persistent://public/test-backlog-quotas/testBacklogQuotasExceeded1650425964-partition-2,
name=sub}, consumerId=2, consumerName=d868bfbe5d, address=/127.0.0.1:53830}
```
Steps to reproduce:
1. Run `pulsar-client-cpp/pulsar-test-service-start.sh` to start a
standalone with anonymous user roles enabled.
2. Create a consumer and a producer on the same topic.
3. Send some messages so that the backlog exceeds 1 KB.
4. Change the backlog policy to
`{"policy":"producer_request_hold","limitSize":1024}`.
5. Recreate the producer **without closing the existing 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]
