You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2020/06/23 15:58:13 UTC
[GitHub] [pulsar] xuehuanran opened a new issue #7344: The python consumer cannot receive the data of topic.
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
[GitHub] [pulsar] xuehuanran commented on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
xuehuanran commented on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648534076
> Do you have the code example you are using for testing? Also, can you provide the sequence on how to re-produce the issue?
Ok, I have updated and add the code example.
----------------------------------------------------------------
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
[GitHub] [pulsar] ptirupac-tibco edited a comment on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
ptirupac-tibco edited a comment on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648908198
I wasn't able to replicate the issue in the following env:
**Environment**
macOS-10.15
python pulsar-client==2.4.2
Puslar-2.5.0 (_standalone_)
Producer Sample:
Consumer Sample:
@xuehuanran how often do you see the issue?
----------------------------------------------------------------
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
[GitHub] [pulsar] ptirupac-tibco commented on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
ptirupac-tibco commented on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648908198
I wasn't able to replicate the issue in the following env:
**Environment**
macOS-10.15
python pulsar-client==2.4.2
Puslar-2.5.0
Producer Sample:
Consumer Sample:
@xuehuanran how often do you see the issue?
----------------------------------------------------------------
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
[GitHub] [pulsar] sijie commented on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
sijie commented on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648532055
Do you have the code example you are using for testing? Also, can you provide the sequence on how to re-produce the issue?
----------------------------------------------------------------
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
[GitHub] [pulsar] xuehuanran commented on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
xuehuanran commented on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648533926
Ok, I have updated and add the code example.
----------------------------------------------------------------
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
[GitHub] [pulsar] xuehuanran removed a comment on issue #7344: The python consumer cannot receive the data of topic.
Posted by GitBox <gi...@apache.org>.
xuehuanran removed a comment on issue #7344:
URL: https://github.com/apache/pulsar/issues/7344#issuecomment-648533926
Ok, I have updated and add the code example.
----------------------------------------------------------------
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