massakam commented on PR #19298:
URL: https://github.com/apache/pulsar/pull/19298#issuecomment-1398471160
> Have you tested it with pulsar-shell?
It seems to work fine on pulsar-shell as well.
```sh
$ ./bin/pulsar-shell
Using directory: /home/massakam/.pulsar-shell
Welcome to Pulsar shell!
Service URL: pulsar://localhost:6650/
Admin URL: http://localhost:8080/
Type help to get started or try the autocompletion (TAB button).
Type exit or quit to end the shell session.
default(localhost)> client read -m Earliest -n 5
persistent://public/default/t1
2023-01-20T23:25:24,112+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x05f137b5,
L:/127.0.0.1:43390 - R:localhost/127.0.0.1:6650]] Connected to server
2023-01-20T23:25:24,118+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar
consumer status recorder with config:
{"topicNames":["persistent://public/default/t1"],"topicsPattern":null,"subscriptionName":"reader-749d586940","subscriptionType":"Exclusive","subscriptionProperties":null,"subscriptionMode":"NonDurable","receiverQueueSize":1000,"acknowledgementsGroupTimeMicros":100000,"maxAcknowledgmentGroupSize":1000,"negativeAckRedeliveryDelayMicros":60000000,"maxTotalReceiverQueueSizeAcrossPartitions":50000,"consumerName":null,"ackTimeoutMillis":0,"tickDurationMillis":1000,"priorityLevel":0,"maxPendingChunkedMessage":10,"autoAckOldestChunkedMessageOnQueueFull":false,"expireTimeOfIncompleteChunkedMessageMillis":60000,"cryptoFailureAction":"FAIL","properties":{},"readCompacted":false,"subscriptionInitialPosition":"Latest","patternAutoDiscoveryPeriod":60,"regexSubscriptionMode":"PersistentOnly","deadLetterPolicy":null,"retryEnable
":false,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"replicateSubscriptionState":false,"resetIncludeHead":false,"batchIndexAckEnabled":false,"ackReceiptEnabled":false,"poolMessages":true,"startPaused":false,"autoScaledReceiverQueueSizeEnabled":false,"topicConfigurations":[],"maxPendingChuckedMessage":10}
2023-01-20T23:25:24,119+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config:
{"serviceUrl":"pulsar://localhost:6650/","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":6,"numListenerThreads":6,"connectionsPerBroker":1,"connectionMaxIdleSeconds":180,"useTcpNoDelay":true,"useTls":false,"tlsKeyFilePath":"","tlsCertificateFilePath":"","tlsTrustCertsFilePath":"","tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"readTimeoutMs":60000,"autoCertRefreshSeconds":300,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreT
ls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":"","tlsKeyStorePassword":"*****","tlsTrustStoreType":"JKS","tlsTrustStorePath":"","tlsTrustStorePassword":"*****","tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dnsLookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null}
2023-01-20T23:25:24,121+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://public/default/t1][reader-749d586940] Subscribing to topic on cnx
[id: 0x05f137b5, L:/127.0.0.1:43390 - R:localhost/127.0.0.1:6650], consumerId 0
2023-01-20T23:25:24,124+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://public/default/t1][reader-749d586940] Subscribed to topic on
localhost/127.0.0.1:6650 -- consumer: 0
----- got message -----
key:[null], properties:[], content:test
----- got message -----
key:[null], properties:[], content:test
----- got message -----
key:[null], properties:[], content:test
----- got message -----
key:[null], properties:[], content:test
----- got message -----
key:[null], properties:[], content:test
2023-01-20T23:25:24,135+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/default/t1]
[reader-749d586940] Closed consumer
2023-01-20T23:25:24,137+0900 [main] INFO
org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL:
pulsar://localhost:6650/
2023-01-20T23:25:24,137+0900 [pulsar-client-io-71-3] INFO
org.apache.pulsar.client.impl.ClientCnx - [id: 0x05f137b5, L:/127.0.0.1:43390 !
R:localhost/127.0.0.1:6650] Disconnected
2023-01-20T23:25:26,141+0900 [main] INFO
org.apache.pulsar.client.cli.PulsarClientTool - 5 messages successfully read
default(localhost)>
```
--
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]
