ujjain7194 opened a new issue, #21593: URL: https://github.com/apache/pulsar/issues/21593
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar version 2.10.4 OS: Ubuntu(version=22.04) Client(Python): pulsar-client(Version=3.3.0) ### Minimal reproduce step 1. Create a partitioned topic with one partition `bin/pulsar-admin topics create-partitioned-topic persistent://public/default/test-consumer -p 1` 2. Publish some messages 3. Create one consumer as following `consumer = client.subscribe( topic='persistent://public/default/test-consumer', subscription_name='test', consumer_type=ConsumerType.Shared, initial_position=InitialPosition.Earliest, receiver_queue_size=1, max_total_receiver_queue_size_across_partitions=1, consumer_name=None, negative_ack_redelivery_delay_ms=60000, unacked_messages_timeout_ms=3600000)` 4. Receive and ack one message `consumer.receive(timeout_millis=30000)` `consumer.acknowledge(message=message_id)` 5. Check stats(Its showing 2 unack messages but its not received yet, also if we create another consumer and try to consume messages its not delivering) ### What did you expect to see? It should not show 2 unack messages before even receiving messages since receiver size is 1. ### What did you see instead? I can stats as following **Command**: bin/pulsar-admin topics partitioned-stats persistent://public/default/test-consumer { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.07158759338136238, "msgThroughputOut" : 4.271393071754622, "bytesInCounter" : 179, "msgInCounter" : 3, "bytesOutCounter" : 179, "msgOutCounter" : 3, "averageMsgSize" : 0.0, "msgChunkPublished" : false, "storageSize" : 179, "backlogSize" : 120, "publishRateLimitedTimes" : 0, "earliestMsgPublishTimeInBacklogs" : 0, "offloadedStorageSize" : 0, "lastOffloadLedgerId" : 0, "lastOffloadSuccessTimeStamp" : 0, "lastOffloadFailureTimeStamp" : 0, "publishers" : [ ], "waitingPublishers" : 0, "subscriptions" : { "test" : { "msgRateOut" : 0.07158759338136238, "msgThroughputOut" : 4.271393071754622, "bytesOutCounter" : 179, "msgOutCounter" : 3, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0, "msgBacklog" : 2, "backlogSize" : 0, "earliestMsgPublishTimeInBacklog" : 0, "msgBacklogNoDelayed" : 2, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 2, "msgRateExpired" : 0.0, "totalMsgExpired" : 0, "lastExpireTimestamp" : 0, "lastConsumedFlowTimestamp" : 0, "lastConsumedTimestamp" : 0, "lastAckedTimestamp" : 0, "lastMarkDeleteAdvancedTimestamp" : 0, "consumers" : [ { "msgRateOut" : 0.07158759338136238, "msgThroughputOut" : 4.271393071754622, "bytesOutCounter" : 179, "msgOutCounter" : 3, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.023862530971099603, "chunkedMessageRate" : 0.0, "availablePermits" : 0, "unackedMessages" : 2, "avgMessagesPerEntry" : 0, "blockedConsumerOnUnackedMsgs" : false, "lastAckedTimestamp" : 0, "lastConsumedTimestamp" : 0 }, { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 0, "msgOutCounter" : 0, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0.0, "availablePermits" : 1, "unackedMessages" : 0, "avgMessagesPerEntry" : 0, "blockedConsumerOnUnackedMsgs" : false, "lastAckedTimestamp" : 0, "lastConsumedTimestamp" : 0 } ], "isDurable" : true, "isReplicated" : false, "allowOutOfOrderDelivery" : false, "consumersAfterMarkDeletePosition" : { }, "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0, "subscriptionProperties" : { }, "durable" : true, "replicated" : false } }, "replication" : { }, "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0, "compaction" : { "lastCompactionRemovedEventCount" : 0, "lastCompactionSucceedTimestamp" : 0, "lastCompactionFailedTimestamp" : 0, "lastCompactionDurationTimeInMills" : 0 }, "metadata" : { "partitions" : 1 }, "partitions" : { } } ### Anything else? _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
