pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [pulsar] xuehuanran opened a new issue #7344: The python consumer cannot receive the data of topic.
Date Tue, 23 Jun 2020 15:58:13 GMT

xuehuanran opened a new issue #7344:
URL: https://github.com/apache/pulsar/issues/7344


   The consumer of python client somtimes cannot receive the data of a persistent topic. The
receive is blocked.
   
   e.g. 
   The topic name is "persistent://public/default/huanran_202006232213_public_key", and the
stats is shown as below.
   `{
     "msgRateIn" : 0.0,
     "msgThroughputIn" : 0.0,
     "msgRateOut" : 0.0,
     "msgThroughputOut" : 0.0,
     "averageMsgSize" : 0.0,
     "storageSize" : 2694,
     "backlogSize" : 0,
     "publishers" : [ {
       "msgRateIn" : 0.0,
       "msgThroughputIn" : 0.0,
       "averageMsgSize" : 0.0,
       "producerId" : 0,
       "metadata" : { },
       "address" : "/127.0.0.1:56474",
       "producerName" : "standalone-17-48",
       "connectedSince" : "2020-06-23T22:14:05.502+08:00",
       "clientVersion" : "2.4.1"
     } ],
     "subscriptions" : {
       "huanran_202006232213_public_key_sub" : {
         "msgRateOut" : 0.0,
         "msgThroughputOut" : 0.0,
         "msgRateRedeliver" : 0.0,
         "msgBacklog" : 0,
         "blockedSubscriptionOnUnackedMsgs" : false,
         "msgDelayed" : 0,
         "unackedMessages" : 0,
         "type" : "Exclusive",
         "activeConsumerName" : "914e9d",
         "msgRateExpired" : 0.0,
         "lastExpireTimestamp" : 0,
         "consumers" : [ {
           "msgRateOut" : 0.0,
           "msgThroughputOut" : 0.0,
           "msgRateRedeliver" : 0.0,
           "consumerName" : "914e9d",
           "availablePermits" : 10,
           "unackedMessages" : 0,
           "blockedConsumerOnUnackedMsgs" : false,
           "metadata" : { },
           "address" : "/127.0.0.1:56477",
           "connectedSince" : "2020-06-23T22:14:16.453+08:00",
           "clientVersion" : "2.4.1"
         } ],
         "isReplicated" : false
       }
     },
     "replication" : { },
     "deduplicationStatus" : "Disabled",
     "bytesInCounter" : 2694,
     "msgInCounter" : 2
   }`
   
   `{
     "entriesAddedCounter" : 2,
     "numberOfEntries" : 2,
     "totalSize" : 2694,
     "currentLedgerEntries" : 2,
     "currentLedgerSize" : 2694,
     "lastLedgerCreatedTimestamp" : "2020-06-23T22:14:05.5+08:00",
     "waitingCursorsCount" : 1,
     "pendingAddEntriesCount" : 0,
     "lastConfirmedEntry" : "4644:1",
     "state" : "LedgerOpened",
     "ledgers" : [ {
       "ledgerId" : 4644,
       "entries" : 0,
       "size" : 0,
       "offloaded" : false
     } ],
     "cursors" : {
       "huanran_202006232213_public_key_sub" : {
         "markDeletePosition" : "4644:1",
         "readPosition" : "4644:2",
         "waitingReadOp" : false,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : 2,
         "cursorLedger" : 4648,
         "cursorLedgerLastEntry" : 0,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2020-06-23T22:14:16.447+08:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       }
     }
   }
   `
   
   The `msg = consumer.receive() `  is block.


----------------------------------------------------------------
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:
users@infra.apache.org



Mime
View raw message