dsmlily opened a new issue #147: consumer.Receive () is blocking, availablePermits are decreasing, but msgBacklog is increasing URL: https://github.com/apache/pulsar-client-go/issues/147 #### Expected behavior { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 0, "publishers" : [ ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 0, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1024, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 2967, "publishers" : [ { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "producerId" : 1, "metadata" : { }, "producerName" : "qa-pulsar-ten-5-279", "connectedSince" : "2019-12-26T20:56:40.736+08:00", "address" : "/10.32.68.213:43156" } ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 1, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1021, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 5681, "publishers" : [ { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "producerId" : 1, "metadata" : { }, "producerName" : "qa-pulsar-ten-5-279", "connectedSince" : "2019-12-26T20:56:40.736+08:00", "address" : "/10.32.68.213:43156" } ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 3, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1019, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 7169, "publishers" : [ { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "producerId" : 1, "metadata" : { }, "producerName" : "qa-pulsar-ten-5-279", "connectedSince" : "2019-12-26T20:56:40.736+08:00", "address" : "/10.32.68.213:43156" } ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 5, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1017, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 8718, "publishers" : [ { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "producerId" : 1, "metadata" : { }, "producerName" : "qa-pulsar-ten-5-279", "connectedSince" : "2019-12-26T20:56:40.736+08:00", "address" : "/10.32.68.213:43156" } ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 8, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1014, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "averageMsgSize" : 0.0, "storageSize" : 6, "publishers" : [ { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "producerId" : 1, "metadata" : { }, "producerName" : "qa-pulsar-ten-5-279", "connectedSince" : "2019-12-26T20:56:40.736+08:00", "address" : "/10.32.68.213:43156" } ], "subscriptions" : { "response:proxy:8787:9:1577364969737" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "msgBacklog" : 0, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Failover", "activeConsumerName" : "lxxlc", "msgRateExpired" : 0.0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "msgRateRedeliver" : 0.0, "consumerName" : "lxxlc", "availablePermits" : 1011, "unackedMessages" : 0, "blockedConsumerOnUnackedMsgs" : false, "metadata" : { }, "connectedSince" : "2019-12-26T20:56:09.832+08:00", "address" : "/10.32.68.213:57108" } ], "isReplicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled" } #### System configuration **Pulsar version**: 2.4.0 **type** : Failover
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
