Skip to content

Instantly share code, notes, and snippets.

@jiazhai

jiazhai/TestS3Offload.txt

Created November 22, 2018 13:19
Show Gist options
  • Save jiazhai/f758298f5a7c53081d2c80b3a575e4b7 to your computer and use it in GitHub Desktop.
Save jiazhai/f758298f5a7c53081d2c80b3a575e4b7 to your computer and use it in GitHub Desktop.
Download ZIP
TestS3Offload fail
Raw
TestS3Offload.txt
org.apache.pulsar.tests.integration.offload.TestS3Offload.tiered-storage-test-suite (from TestSuite)
Failing for the past 1 build (Since 失败#5056 )
运行时间：1 分 16 秒
添加说明
Error Message
arrays differ firstly at element [15]; expected value is <48> but was <49>.
Stacktrace
java.lang.AssertionError: arrays differ firstly at element [15]; expected value is <48> but was <49>.
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.assertEquals(Assert.java:195)
at org.testng.Assert.assertEquals(Assert.java:179)
at org.apache.pulsar.tests.integration.offload.TestS3Offload.testPublishOffloadAndConsumeViaCLI(TestS3Offload.java:149)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Standard Output
------- Starting test [TestClass name=class org.apache.pulsar.tests.integration.offload.TestS3Offload].tiered-storage-test-suite([pulsar://localhost:44574, http://localhost:44573])-------
13:02:26.736 [testcontainers-netty-1-13:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin tenants create --allowed-clusters TestS3Offload-kszcs --admin-roles offload-admin s3-offload-test-cli-yout): Executing...
13:02:30.763 [testcontainers-netty-1-13:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin tenants create --allowed-clusters TestS3Offload-kszcs --admin-roles offload-admin s3-offload-test-cli-yout): Done
13:02:30.766 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin tenants create --allowed-clusters TestS3Offload-kszcs --admin-roles offload-admin s3-offload-test-cli-yout): completed with 0
13:02:30.772 [testcontainers-netty-1-16:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin namespaces create --clusters TestS3Offload-kszcs s3-offload-test-cli-yout/ns1): Executing...
13:02:34.597 [testcontainers-netty-1-16:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin namespaces create --clusters TestS3Offload-kszcs s3-offload-test-cli-yout/ns1): Done
13:02:34.598 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin namespaces create --clusters TestS3Offload-kszcs s3-offload-test-cli-yout/ns1): completed with 0
13:02:34.603 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x03f4be1f, L:/127.0.0.1:55610 - R:localhost/127.0.0.1:44574]] Connected to server
13:02:34.614 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ProducerStatsRecorderImpl@101] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {
"topicName" : "persistent://s3-offload-test-cli-yout/ns1/topic1",
"producerName" : null,
"sendTimeoutMs" : 30000,
"blockIfQueueFull" : true,
"maxPendingMessages" : 1000,
"maxPendingMessagesAcrossPartitions" : 50000,
"messageRoutingMode" : "RoundRobinPartition",
"hashingScheme" : "JavaStringHash",
"cryptoFailureAction" : "FAIL",
"batchingMaxPublishDelayMicros" : 1000,
"batchingMaxMessages" : 1000,
"batchingEnabled" : false,
"compressionType" : "NONE",
"initialSequenceId" : null,
"properties" : { }
}
13:02:34.614 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ProducerStatsRecorderImpl@102] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {
"serviceUrl" : "pulsar://localhost:44574",
"operationTimeoutMs" : 30000,
"statsIntervalSeconds" : 60,
"numIoThreads" : 1,
"numListenerThreads" : 1,
"connectionsPerBroker" : 1,
"useTcpNoDelay" : true,
"useTls" : false,
"tlsTrustCertsFilePath" : "",
"tlsAllowInsecureConnection" : false,
"tlsHostnameVerificationEnable" : false,
"concurrentLookupRequest" : 5000,
"maxLookupRequest" : 50000,
"maxNumberOfRejectedRequestPerConnection" : 50,
"keepAliveIntervalSeconds" : 30,
"connectionTimeoutMs" : 10000
}
13:02:34.715 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x311a9489, L:/127.0.0.1:55638 - R:localhost/127.0.0.1:44574]] Connected to server
13:02:34.715 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ClientCnx@154] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x311a9489, L:/127.0.0.1:55638 - R:localhost/127.0.0.1:44574] Connected through proxy to target broker at pulsar-broker-0:6650
13:02:34.726 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ProducerImpl@886] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1] [null] Creating producer on cnx [id: 0x311a9489, L:/127.0.0.1:55638 - R:localhost/127.0.0.1:44574]
13:02:34.880 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ProducerImpl@934] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1] [TestS3Offload-kszcs-2-0] Created producer on cnx [id: 0x311a9489, L:/127.0.0.1:55638 - R:localhost/127.0.0.1:44574]
13:02:34.892 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@102] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer perf with config: {
"topicNames" : [ "persistent://s3-offload-test-cli-yout/ns1/topic1" ],
"topicsPattern" : null,
"subscriptionName" : "my-sub",
"subscriptionType" : "Exclusive",
"receiverQueueSize" : 1000,
"acknowledgementsGroupTimeMicros" : 100000,
"maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
"consumerName" : null,
"ackTimeoutMillis" : 0,
"priorityLevel" : 0,
"cryptoFailureAction" : "FAIL",
"properties" : { },
"readCompacted" : false,
"subscriptionInitialPosition" : "Latest",
"patternAutoDiscoveryPeriod" : 1,
"subscriptionTopicsMode" : "PERSISTENT",
"deadLetterPolicy" : null
}
13:02:34.893 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@103] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
"serviceUrl" : "pulsar://localhost:44574",
"operationTimeoutMs" : 30000,
"statsIntervalSeconds" : 60,
"numIoThreads" : 1,
"numListenerThreads" : 1,
"connectionsPerBroker" : 1,
"useTcpNoDelay" : true,
"useTls" : false,
"tlsTrustCertsFilePath" : "",
"tlsAllowInsecureConnection" : false,
"tlsHostnameVerificationEnable" : false,
"concurrentLookupRequest" : 5000,
"maxLookupRequest" : 50000,
"maxNumberOfRejectedRequestPerConnection" : 50,
"keepAliveIntervalSeconds" : 30,
"connectionTimeoutMs" : 10000
}
13:02:34.898 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConsumerImpl@514] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribing to topic on cnx [id: 0x311a9489, L:/127.0.0.1:55638 - R:localhost/127.0.0.1:44574]
13:02:35.057 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConsumerImpl@559] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribed to topic on localhost/127.0.0.1:44574 -- consumer: 0
13:02:35.067 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ConsumerImpl@719] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Closed consumer
13:02:36.364 [testcontainers-netty-1-19:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 100G persistent://s3-offload-test-cli-yout/ns1/topic1): Executing...
13:02:40.096 [testcontainers-netty-1-19:org.apache.pulsar.tests.integration.utils.DockerUtils$2@194] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 100G persistent://s3-offload-test-cli-yout/ns1/topic1): STDOUT: Nothing to offload
13:02:40.127 [testcontainers-netty-1-19:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 100G persistent://s3-offload-test-cli-yout/ns1/topic1): Done
13:02:40.131 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 100G persistent://s3-offload-test-cli-yout/ns1/topic1): completed with 0
13:02:40.137 [testcontainers-netty-1-22:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status persistent://s3-offload-test-cli-yout/ns1/topic1): Executing...
13:02:44.029 [testcontainers-netty-1-22:org.apache.pulsar.tests.integration.utils.DockerUtils$2@194] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status persistent://s3-offload-test-cli-yout/ns1/topic1): STDOUT: Offload has not been run for persistent://s3-offload-test-cli-yout/ns1/topic1 since broker startup
13:02:44.054 [testcontainers-netty-1-22:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status persistent://s3-offload-test-cli-yout/ns1/topic1): Done
13:02:44.055 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status persistent://s3-offload-test-cli-yout/ns1/topic1): completed with 0
13:02:44.059 [testcontainers-netty-1-25:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 1M persistent://s3-offload-test-cli-yout/ns1/topic1): Executing...
13:02:47.900 [testcontainers-netty-1-25:org.apache.pulsar.tests.integration.utils.DockerUtils$2@194] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 1M persistent://s3-offload-test-cli-yout/ns1/topic1): STDOUT: Offload triggered for persistent://s3-offload-test-cli-yout/ns1/topic1 for messages before 19:0:-1
13:02:47.934 [testcontainers-netty-1-25:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 1M persistent://s3-offload-test-cli-yout/ns1/topic1): Done
13:02:47.936 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload --size-threshold 1M persistent://s3-offload-test-cli-yout/ns1/topic1): completed with 0
13:02:47.939 [testcontainers-netty-1-28:org.apache.pulsar.tests.integration.utils.DockerUtils$2@189] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status -w persistent://s3-offload-test-cli-yout/ns1/topic1): Executing...
13:02:51.773 [testcontainers-netty-1-28:org.apache.pulsar.tests.integration.utils.DockerUtils$2@194] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status -w persistent://s3-offload-test-cli-yout/ns1/topic1): STDOUT: Offload was a success
13:02:51.809 [testcontainers-netty-1-28:org.apache.pulsar.tests.integration.utils.DockerUtils$2@209] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status -w persistent://s3-offload-test-cli-yout/ns1/topic1): Done
13:02:51.811 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.utils.DockerUtils@231] INFO org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(8fed4fe73bef786bffe6b59fb3a0592e21b2b83526832b6f8e77caff3c958e33:/pulsar/bin/pulsar-admin topics offload-status -w persistent://s3-offload-test-cli-yout/ns1/topic1): completed with 0
13:02:51.823 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ProducerImpl@617] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1] [TestS3Offload-kszcs-2-0] Closed Producer
13:02:51.824 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.client.impl.PulsarClientImpl@686] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: localhost:44574
13:02:51.827 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x311a9489, L:/127.0.0.1:55638 ! R:localhost/127.0.0.1:44574] Disconnected
13:02:51.827 [pulsar-client-io-140-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x03f4be1f, L:/127.0.0.1:55610 ! R:localhost/127.0.0.1:44574] Disconnected
13:02:53.222 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase@186] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver at metadata service uri zk+null://localhost:44568/ledgers : zkServers = localhost:44568, ledgersRootPath = /ledgers.
13:02:53.253 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1-EventThread:org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@130] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
13:02:53.258 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl@313] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Failed to initialize DNS Resolver org.apache.bookkeeper.net.ScriptBasedMapping, used default subnet resolver : java.lang.RuntimeException: No network topology script is found when using script based DNS resolver.
13:02:53.259 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl@261] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Initialize rackaware ensemble placement policy @ <Bookie:67.195.81.168:0> @ /default-rack : org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl$DefaultResolver.
13:02:53.259 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl@271] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Not weighted
13:02:53.260 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.bookkeeper.client.BookKeeper@527] INFO org.apache.bookkeeper.client.BookKeeper - Weighted ledger placement is not enabled
13:02:53.325 [BookKeeperClientScheduler-OrderedScheduler-0-0:org.apache.bookkeeper.net.NetworkTopologyImpl@427] INFO org.apache.bookkeeper.net.NetworkTopologyImpl - Adding a new node: /default-rack/pulsar-bookie-0:3181
13:02:53.326 [BookKeeperClientScheduler-OrderedScheduler-0-0:org.apache.bookkeeper.net.NetworkTopologyImpl@427] INFO org.apache.bookkeeper.net.NetworkTopologyImpl - Adding a new node: /default-rack/pulsar-bookie-1:3181
13:03:08.925 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.containers.PulsarContainer@126] INFO org.apache.pulsar.tests.integration.containers.PulsarContainer - Start pulsar service pulsar-broker-0 at container /TestS3Offload-kszcs-pulsar-broker-0
13:03:08.926 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.tests.integration.offload.TestS3Offload@143] INFO org.apache.pulsar.tests.integration.offload.TestS3Offload - Read back the data (which would be in that first ledger)
13:03:08.932 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x58e07d14, L:/127.0.0.1:33002 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:08.943 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@102] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer perf with config: {
"topicNames" : [ "persistent://s3-offload-test-cli-yout/ns1/topic1" ],
"topicsPattern" : null,
"subscriptionName" : "my-sub",
"subscriptionType" : "Exclusive",
"receiverQueueSize" : 1000,
"acknowledgementsGroupTimeMicros" : 100000,
"maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
"consumerName" : null,
"ackTimeoutMillis" : 0,
"priorityLevel" : 0,
"cryptoFailureAction" : "FAIL",
"properties" : { },
"readCompacted" : false,
"subscriptionInitialPosition" : "Latest",
"patternAutoDiscoveryPeriod" : 1,
"subscriptionTopicsMode" : "PERSISTENT",
"deadLetterPolicy" : null
}
13:03:08.944 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@103] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
"serviceUrl" : "pulsar://localhost:44574",
"operationTimeoutMs" : 30000,
"statsIntervalSeconds" : 60,
"numIoThreads" : 1,
"numListenerThreads" : 1,
"connectionsPerBroker" : 1,
"useTcpNoDelay" : true,
"useTls" : false,
"tlsTrustCertsFilePath" : "",
"tlsAllowInsecureConnection" : false,
"tlsHostnameVerificationEnable" : false,
"concurrentLookupRequest" : 5000,
"maxLookupRequest" : 50000,
"maxNumberOfRejectedRequestPerConnection" : 50,
"keepAliveIntervalSeconds" : 30,
"connectionTimeoutMs" : 10000
}
13:03:09.382 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xaf37c904, L:/127.0.0.1:33082 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:09.383 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@154] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xaf37c904, L:/127.0.0.1:33082 - R:localhost/127.0.0.1:44574] Connected through proxy to target broker at pulsar-broker-0:6650
13:03:09.395 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerImpl@514] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribing to topic on cnx [id: 0xaf37c904, L:/127.0.0.1:33082 - R:localhost/127.0.0.1:44574]
13:03:10.977 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerImpl@559] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribed to topic on localhost/127.0.0.1:44574 -- consumer: 0
13:03:14.770 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xaf37c904, L:/127.0.0.1:33082 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:14.772 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@109] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Closed connection [id: 0xaf37c904, L:/127.0.0.1:33082 ! R:localhost/127.0.0.1:44574] -- Will try again in 0.1 s
13:03:14.875 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@112] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after timeout
13:03:14.884 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x58e07d14, L:/127.0.0.1:33002 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:14.885 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:14.887 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:14.888 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 0.185 s
13:03:14.888 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x58e07d14, L:/127.0.0.1:33002 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:15.074 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:15.077 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x522d69ce, L:/127.0.0.1:34062 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:15.090 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x522d69ce, L:/127.0.0.1:34062 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:15.091 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:15.093 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:15.093 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 0.399 s
13:03:15.094 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x522d69ce, L:/127.0.0.1:34062 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:15.494 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:15.496 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x0a2a05c8, L:/127.0.0.1:34136 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:15.506 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x0a2a05c8, L:/127.0.0.1:34136 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:15.507 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:15.509 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:15.509 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 0.776 s
13:03:15.509 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x0a2a05c8, L:/127.0.0.1:34136 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:16.286 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:16.288 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xdf9672a0, L:/127.0.0.1:34282 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:16.302 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0xdf9672a0, L:/127.0.0.1:34282 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:16.302 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:16.305 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:16.305 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 1.542 s
13:03:16.306 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xdf9672a0, L:/127.0.0.1:34282 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:17.848 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:17.850 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x70b20834, L:/127.0.0.1:34542 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:17.860 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x70b20834, L:/127.0.0.1:34542 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:17.861 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:17.863 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:17.864 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 3.054 s
13:03:17.864 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x70b20834, L:/127.0.0.1:34542 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:20.920 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:20.926 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xcbe93d99, L:/127.0.0.1:35040 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:20.934 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0xcbe93d99, L:/127.0.0.1:35040 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:20.935 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:20.937 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650
13:03:20.937 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: pulsar-broker-0/172.18.0.6:6650 -- Will try again in 6.324 s
13:03:20.938 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xcbe93d99, L:/127.0.0.1:35040 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:27.264 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:27.267 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x220b4c01, L:/127.0.0.1:36080 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:27.273 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@720] ERROR org.apache.pulsar.client.impl.ClientCnx - [id: 0x220b4c01, L:/127.0.0.1:36080 - R:localhost/127.0.0.1:44574] Close connection because received internal-server error No active broker is available
13:03:27.273 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.BinaryProtoLookupService@151] WARN org.apache.pulsar.client.impl.BinaryProtoLookupService - [persistent://s3-offload-test-cli-yout/ns1/topic1] failed to send lookup request : org.apache.pulsar.client.api.PulsarClientException$LookupException: No active broker is available
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException$LookupException: No active broker is available
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) ~[?:1.8.0_191]
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) [?:1.8.0_191]
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) [?:1.8.0_191]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:380) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:118) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:806) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:404) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: org.apache.pulsar.client.api.PulsarClientException$LookupException: No active broker is available
at org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:809) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
at org.apache.pulsar.client.impl.ClientCnx.handleLookupResponse(ClientCnx.java:381) ~[pulsar-client-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
... 19 more
13:03:27.275 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@74] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: No active broker is available
13:03:27.275 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionHandler@92] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: No active broker is available -- Will try again in 12.738 s
13:03:27.275 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x220b4c01, L:/127.0.0.1:36080 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:40.014 [pulsar-timer-145-1:org.apache.pulsar.client.impl.ConnectionHandler@96] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Reconnecting after connection was closed
13:03:40.020 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xc4aabfd7, L:/127.0.0.1:38212 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:40.408 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConnectionPool@180] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x10ea5408, L:/127.0.0.1:38278 - R:localhost/127.0.0.1:44574]] Connected to server
13:03:40.408 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@154] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x10ea5408, L:/127.0.0.1:38278 - R:localhost/127.0.0.1:44574] Connected through proxy to target broker at pulsar-broker-0:6650
13:03:40.421 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerImpl@514] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribing to topic on cnx [id: 0x10ea5408, L:/127.0.0.1:38278 - R:localhost/127.0.0.1:44574]
13:03:41.289 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerImpl@559] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1][my-sub] Subscribed to topic on localhost/127.0.0.1:44574 -- consumer: 0
13:03:43.074 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ConsumerImpl@719] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://s3-offload-test-cli-yout/ns1/topic1] [my-sub] Closed consumer
13:03:43.075 [TestNG-method=testPublishOffloadAndConsumeViaCLI-1:org.apache.pulsar.client.impl.PulsarClientImpl@686] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: localhost:44574
13:03:43.078 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xc4aabfd7, L:/127.0.0.1:38212 ! R:localhost/127.0.0.1:44574] Disconnected
13:03:43.079 [pulsar-client-io-143-1:org.apache.pulsar.client.impl.ClientCnx@183] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x10ea5408, L:/127.0.0.1:38278 ! R:localhost/127.0.0.1:44574] Disconnected
!!!!!!!!! FAILURE-- [TestClass name=class org.apache.pulsar.tests.integration.offload.TestS3Offload].tiered-storage-test-suite([pulsar://localhost:44574, http://localhost:44573])-------
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment