congbobo184 opened a new issue, #192: URL: https://github.com/apache/pulsar-client-cpp/issues/192
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version pulsar: apachepulsar/pulsar:2.11.0 os : mac 12.6 cpp client version : main branch ### Minimal reproduce step 1. ./pulsar-test-service-start.sh 2. cd tests 3. ./pulsar-tests ### What did you expect to see? run all tests successful ### What did you see instead? ``` [ OK ] BasicEndToEndTest.testMessageListener (5315 ms) [ RUN ] BasicEndToEndTest.testMessageListenerPause 2023-02-13 15:15:32.932 INFO [0x1049c4580] BasicEndToEndTest:922 | res = 204 2023-02-13 15:15:32.933 INFO [0x1049c4580] ClientConnection:191 | [<none> -> pulsar://localhost:6650] Create ClientConnection, timeout=10000 2023-02-13 15:15:32.933 INFO [0x1049c4580] ConnectionPool:97 | Created connection for pulsar://localhost:6650 2023-02-13 15:15:32.934 INFO [0x16c7c3000] ClientConnection:389 | [[::1]:51554 -> [::1]:6650] Connected to broker 2023-02-13 15:15:32.945 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, ] Getting connection from pool 2023-02-13 15:15:32.979 INFO [0x16c7c3000] ProducerImpl:204 | [persistent://public/default/partition-testMessageListenerPause, ] Created producer on broker [[::1]:51554 -> [::1]:6650] 2023-02-13 15:15:32.979 INFO [0x1049c4580] Client:87 | Subscribing on Topic :partition-testMessageListenerPause 2023-02-13 15:15:32.982 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Getting connection from pool 2023-02-13 15:15:33.002 INFO [0x16c7c3000] ConsumerImpl:257 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Created consumer on broker [[::1]:51554 -> [::1]:6650] 2023-02-13 15:15:33.002 INFO [0x1049c4580] ConsumerImpl:309 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Unsubscribing 2023-02-13 15:15:33.009 INFO [0x16c7c3000] ConsumerImpl:314 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 0] Unsubscribed successfully 2023-02-13 15:15:33.009 INFO [0x1049c4580] Client:87 | Subscribing on Topic :partition-testMessageListenerPause 2023-02-13 15:15:33.012 INFO [0x16c7c3000] HandlerBase:72 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 1] Getting connection from pool 2023-02-13 15:15:33.030 INFO [0x16c7c3000] ConsumerImpl:257 | [persistent://public/default/partition-testMessageListenerPause, subscription-name, 1] Created consumer on broker [[::1]:51554 -> [::1]:6650] libc++abi: terminating with uncaught exception of type std::__1::system_error: condition_variable wait failed: Invalid argument [6] 3453 abort ./pulsar-tests ➜ tests git:(main) ✗ ls ``` topic stats ``` ./pulsar-admin topics stats partition-testMessageListenerPause { "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesInCounter" : 16928, "msgInCounter" : 358, "bytesOutCounter" : 16832, "msgOutCounter" : 356, "averageMsgSize" : 0.0, "msgChunkPublished" : false, "storageSize" : 16928, "backlogSize" : 854, "publishRateLimitedTimes" : 0, "earliestMsgPublishTimeInBacklogs" : 0, "offloadedStorageSize" : 0, "lastOffloadLedgerId" : 0, "lastOffloadSuccessTimeStamp" : 0, "lastOffloadFailureTimeStamp" : 0, "publishers" : [ ], "waitingPublishers" : 0, "subscriptions" : { "subscription-name" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 16832, "msgOutCounter" : 356, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0, "msgBacklog" : 16, "backlogSize" : 0, "earliestMsgPublishTimeInBacklog" : 0, "msgBacklogNoDelayed" : 16, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Exclusive", "msgRateExpired" : 0.0, "totalMsgExpired" : 0, "lastExpireTimestamp" : 0, "lastConsumedFlowTimestamp" : 1676272533027, "lastConsumedTimestamp" : 0, "lastAckedTimestamp" : 0, "lastMarkDeleteAdvancedTimestamp" : 1676272536420, "consumers" : [ ], "isDurable" : true, "isReplicated" : false, "allowOutOfOrderDelivery" : false, "consumersAfterMarkDeletePosition" : { }, "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0, "delayedTrackerMemoryUsage" : 0, "subscriptionProperties" : { }, "filterProcessedMsgCount" : 0, "filterAcceptedMsgCount" : 0, "filterRejectedMsgCount" : 0, "filterRescheduledMsgCount" : 0, "durable" : true, "replicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled", "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0, "delayedMessageIndexSizeInBytes" : 0, "compaction" : { "lastCompactionRemovedEventCount" : 0, "lastCompactionSucceedTimestamp" : 0, "lastCompactionFailedTimestamp" : 0, "lastCompactionDurationTimeInMills" : 0 } } ``` ### 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]
