Debezium Demo Doesn't Work with 2.9.1 and Aurora 5.x #20101

prime-minister-of-fun · 2022-02-15T19:58:00Z

prime-minister-of-fun
Feb 15, 2022

On either amd64 or arm64 Ubuntu images, https://debezium.io/blog/2019/05/23/tutorial-using-debezium-connectors-with-apache-pulsar/ doesn't work with version 2.9.1 binary download.

Tests before running. Pod can connect to AWS with mysql client.

Steps to reproduce:
Download pulsar binaries, extract. https://dlcdn.apache.org/pulsar/pulsar-2.9.1/apache-pulsar-2.9.1-bin.tar.gz
Download connector dependencies per instructions.
apt --assume-yes install wget unzip net-tools scala openjdk-8-jre-headless libcommons-io-java libcommons-lang3-java libcommons-math3-java libcommons-dbcp2-java libavro-java libjackson2-databind-java libcommons-codec-java python3 python3-pip
export environment variables, JAVA_HOME, PULSAR_HOME
start pulsar: ./bin/pulsar standalone. Appears to be running.
Use example debezium-mysql-source-config.yaml and change the hostname and credentials.
Server has multiple MySQL databases that all need to be streamed. Either defining all of them in whitelist, or defining none, doesn't change anything.
Open new terminal, run: bin/pulsar-admin source localrun --source-config-file /setup/debezium-mysql-source.yaml

It takes a minute to start logging. Then looks like the source is just restarting after crashing:

componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:53:45,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.common.nar.FileUtils - Jar file connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar contains META-INF/bundled-dependencies, it may be a NAR file 2022-02-15T19:53:45,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Trying Loading file as NAR file: connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar 2022-02-15T19:53:47,043+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Initialize function class loader for function debezium-kafka-source at function cache manager, functionClassLoader: org.apache.pulsar.common.nar.NarClassLoader[/tmp/pulsar_localrunner_nars_7426220787174598080/pulsar-nar/pulsar-io-kafka-connect-adaptor-2.9.1.nar-unpacked/90ickkj44GhweghdXLZZsw] 2022-02-15T19:53:47,044+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - ThreadContainer starting function with instance config InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:53:47,056+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"all-the-databases","producerName":null,"sendTimeoutMs":0,"blockIfQueueFull":true,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"messageRoutingMode":"CustomPartition","hashingScheme":"Murmur3_32Hash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":10000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false,"properties":{"application":"pulsar-source","id":"public/mysql8pipeline/debezium-kafka-source","instance_hostname":"pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local","instance_id":"0"}} 2022-02-15T19:53:47,141+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"useTcpNoDelay":true,"useTls":false,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null} 2022-02-15T19:53:47,143+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [null] Creating producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:53:47,151+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-22] Created producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:53:47,241+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-22] Closed Producer 2022-02-15T19:54:15,243+0000 [function-timer-thread-6-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/mysql8pipeline/debezium-kafka-source Function Container is dead with following exception. Restarting. java.lang.NullPointerException: null at java.lang.Class.forName0(Native Method) ~[?:1.8.0_312] at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_312] at org.apache.pulsar.io.kafka.connect.AbstractKafkaConnectSource.open(AbstractKafkaConnectSource.java:88) ~[?:?] at org.apache.pulsar.io.kafka.connect.KafkaConnectSource.open(KafkaConnectSource.java:62) ~[?:?] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupInput(JavaInstanceRunnable.java:757) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:232) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:260) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] 2022-02-15T19:54:15,245+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Unloading JAR files for function InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:54:15,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.common.nar.FileUtils - Jar file connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar contains META-INF/bundled-dependencies, it may be a NAR file 2022-02-15T19:54:15,247+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Trying Loading file as NAR file: connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar 2022-02-15T19:54:17,053+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Initialize function class loader for function debezium-kafka-source at function cache manager, functionClassLoader: org.apache.pulsar.common.nar.NarClassLoader[/tmp/pulsar_localrunner_nars_7426220787174598080/pulsar-nar/pulsar-io-kafka-connect-adaptor-2.9.1.nar-unpacked/90ickkj44GhweghdXLZZsw] 2022-02-15T19:54:17,054+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - ThreadContainer starting function with instance config InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:54:17,149+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"all-the-databases","producerName":null,"sendTimeoutMs":0,"blockIfQueueFull":true,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"messageRoutingMode":"CustomPartition","hashingScheme":"Murmur3_32Hash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":10000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false,"properties":{"application":"pulsar-source","id":"public/mysql8pipeline/debezium-kafka-source","instance_hostname":"pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local","instance_id":"0"}} 2022-02-15T19:54:17,151+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"useTcpNoDelay":true,"useTls":false,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null} 2022-02-15T19:54:17,240+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [null] Creating producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:54:17,247+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-23] Created producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:54:17,345+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-23] Closed Producer ^C2022-02-15T19:54:28,778+0000 [Thread-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Unloading JAR files for function InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 }

prime-minister-of-fun · 2022-02-15T20:11:30Z

prime-minister-of-fun
Feb 15, 2022
Author

Here's the output from running pulsar standalone. I stopped it towards the end:

`2022-02-15T20:07:57,250+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Running 1 bookie(s) and advertised them at 127.0.0.1.
2022-02-15T20:07:57,343+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Starting ZK server
2022-02-15T20:07:57,443+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer -
2022-02-15T20:07:57,443+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - ______ _
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - |___ / | |
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / ___ ___ | | __ ___ ___ _ __ ___ _ __
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / / _ \ / _ \ | |/ / / _ \ / _ \ | '_ \ / _ \ | '|
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / | () | | () | | < | / | / | |_) | | / | |
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - /| _/ _/ |_|_\ _| _| | ./ __| ||
2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - | |
2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - ||
2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer -
2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT
2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:host.name=pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local
2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.version=1.8.0_312
2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.vendor=Private Build
2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.class.path=/data/apache-pulsar/conf:::/data/apache-pulsar/lib/com.google.guava-failureaccess-1.0.1.jar:/data/apache-pulsar/lib/io.vertx-vertx-bridge-common-3.9.8.jar:/data/apache-pulsar/lib/org.jctools-jctools-core-2.1.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-socks-4.1.72.Final.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-graphite-3.2.5.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2.jar:/data/apache-pulsar/lib/com.google.code.gson-gson-2.8.6.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-jute-3.6.3.jar:/data/apache-pulsar/lib/jakarta.validation-jakarta.validation-api-2.0.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-haproxy-4.1.72.Final.jar:/data/apache-pulsar/lib/commons-configuration-commons-configuration-1.10.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-common-4.14.2.jar:/data/apache-pulsar/lib/jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar:/data/apache-pulsar/lib/org.reactivestreams-reactive-streams-1.0.3.jar:/data/apache-pulsar/lib/io.gsonfire-gson-fire-1.8.5.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-security-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-common-2.9.1.jar:/data/apache-pulsar/lib/org.apache.thrift-libthrift-0.14.2.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-utils-2.6.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-1.33.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-core-2.12.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient-0.5.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_httpserver-0.5.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.xerial.snappy-snappy-java-1.1.7.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-vertx-http-server-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.checkerframework-checker-qual-3.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-worker-2.9.1.jar:/data/apache-pulsar/lib/io.netty-netty-handler-proxy-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-prometheus-metrics-3.6.3.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-1.2-api-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-runtime-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2-osgi-resource-locator-1.0.3.jar:/data/apache-pulsar/lib/io.grpc-grpc-stub-1.33.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_jetty-0.5.0.jar:/data/apache-pulsar/lib/com.github.zafarkhaja-java-semver-0.9.0.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-web-2.16.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-recipes-5.1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-core-1.6.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-xds-1.33.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar:/data/apache-pulsar/lib/com.squareup.okio-okio-2.8.0.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-locator-2.6.1.jar:/data/apache-pulsar/lib/com.google.re2j-re2j-1.2.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-client-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-auth-1.33.0.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-1.33.0.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-common-3.9.8.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-statelib-4.14.2.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_log4j2-0.5.0.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpclient-4.5.13.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-tools-framework-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-databind-2.12.3.jar:/data/apache-pulsar/lib/org.bitbucket.b_c-jose4j-0.7.6.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-common-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-core-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-original-2.9.1.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-jvm-3.2.5.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-server-4.14.2.jar:/data/apache-pulsar/lib/org.jvnet.mimepull-mimepull-1.9.13.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-multipart-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-testclient-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-shaded-1.33.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-api-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-3.6.3.jar:/data/apache-pulsar/lib/commons-codec-commons-codec-1.15.jar:/data/apache-pulsar/lib/io.netty-netty-codec-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-jackson-0.11.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-tools-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar:/data/apache-pulsar/lib/org.apache.curator-curator-framework-5.1.0.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-memory-0.8.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-secrets-2.9.1.jar:/data/apache-pulsar/lib/com.google.code.findbugs-jsr305-3.0.2.jar:/data/apache-pulsar/lib/io.airlift-aircompressor-0.20.jar:/data/apache-pulsar/lib/com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-prometheus-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcpkix-jdk15on-1.69.jar:/data/apache-pulsar/lib/com.google.auto.value-auto-value-annotations-1.7.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-proto-2.9.1.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-contrib-http-util-0.24.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-server-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-config-validation-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-testmocks-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-utils-2.9.1.jar:/data/apache-pulsar/lib/jakarta.annotation-jakarta.annotation-api-1.3.5.jar:/data/apache-pulsar/lib/jakarta.activation-jakarta.activation-api-1.2.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.12.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-common-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-core-2.9.1.jar:/data/apache-pulsar/lib/javax.servlet-javax.servlet-api-3.1.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.4.32.jar:/data/apache-pulsar/lib/io.vertx-vertx-auth-common-3.9.8.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-1.34.0.jar:/data/apache-pulsar/lib/org.jetbrains-annotations-13.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-bookkeeper-storage-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-slf4j-impl-2.16.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-common-1.4.32.jar:/data/apache-pulsar/lib/io.prometheus.jmx-collector-0.14.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-http-server-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-lite-1.33.0.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-ext-jdk15on-1.69.jar:/data/apache-pulsar/lib/commons-collections-commons-collections-3.2.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-http-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.carrotsearch-hppc-0.7.3.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.12.3.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-1.4.32.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-bookkeeper-stats-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-protocol-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-grpclb-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http-4.1.72.Final.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-api-2.6.1.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.netty-netty-handler-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-buffer-4.1.72.Final.jar:/data/apache-pulsar/lib/com.beust-jcommander-1.78.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-proxy-2.9.1.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-okhttp-4.9.3.jar:/data/apache-pulsar/lib/org.slf4j-slf4j-api-1.7.25.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-common-2.9.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jsonSchema-2.12.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-coordinator-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlets-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_caffeine-0.5.0.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-logging-interceptor-4.9.3.jar:/data/apache-pulsar/lib/org.javassist-javassist-3.25.0-GA.jar:/data/apache-pulsar/lib/org.apache.commons-commons-collections4-4.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-common-4.14.2.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-2.12.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-annotations-2.12.3.jar:/data/apache-pulsar/lib/com.google.errorprone-error_prone_annotations-2.5.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-jakarta.inject-2.6.1.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_servlet-0.5.0.jar:/data/apache-pulsar/lib/javax.websocket-javax.websocket-client-api-1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-models-1.6.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-metadata-2.9.1.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-util-3.11.4.jar:/data/apache-pulsar/lib/io.grpc-grpc-api-1.33.0.jar:/data/apache-pulsar/lib/net.jodah-typetools-0.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/commons-lang-commons-lang-2.6.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-jackson2-1.34.0.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-core-3.2.5.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-3.9.8.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-api-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-proto-12.0.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-proto-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcutil-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpcore-4.4.13.jar:/data/apache-pulsar/lib/io.grpc-grpc-alts-1.33.0.jar:/data/apache-pulsar/lib/javax.validation-validation-api-1.1.0.Final.jar:/data/apache-pulsar/lib/io.netty-netty-common-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_common-0.5.0.jar:/data/apache-pulsar/lib/org.slf4j-jul-to-slf4j-1.7.25.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-api-2.16.0.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-continuation-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar:/data/apache-pulsar/lib/io.swagger-swagger-annotations-1.6.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-proxy-9.4.43.v20210629.jar:/data/apache-pulsar/lib/commons-io-commons-io-2.8.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-codahale-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-api-0.11.1.jar:/data/apache-pulsar/lib/org.hdrhistogram-HdrHistogram-2.1.9.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-io-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.sun.activation-javax.activation-1.2.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-ajax-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-messagecrypto-bc-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-circe-checksum-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-api-2.9.1.jar:/data/apache-pulsar/lib/net.java.dev.jna-jna-4.2.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-common-2.34.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-core-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-websocket-2.9.1.jar:/data/apache-pulsar/lib/commons-logging-commons-logging-1.1.1.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-credentials-0.20.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-client-5.1.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.12.3.jar:/data/apache-pulsar/lib/io.vertx-vertx-core-3.9.8.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-allocator-4.14.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-cpu-affinity-4.14.2.jar:/data/apache-pulsar/lib/commons-cli-commons-cli-1.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-server-4.14.2.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:/data/apache-pulsar/lib/com.google.j2objc-j2objc-annotations-1.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-api-4.14.2.jar:/data/apache-pulsar/lib/com.google.guava-guava-30.1-jre.jar:/data/apache-pulsar/lib/org.glassfish.jersey.inject-jersey-hk2-2.34.jar:/data/apache-pulsar/lib/org.yaml-snakeyaml-1.27.jar:/data/apache-pulsar/lib/io.grpc-grpc-context-1.33.0.jar:/data/apache-pulsar/lib/org.rocksdb-rocksdbjni-6.10.2.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk7-1.4.32.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-oauth2-http-0.20.0.jar:/data/apache-pulsar/lib/org.apache.commons-commons-compress-1.21.jar:/data/apache-pulsar/lib/jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2-tests.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http2-4.1.72.Final.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-api-0.18.0.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-3.11.4.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-services-1.33.0.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-12.0.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-bouncy-castle-bc-2.9.1-pkg.jar:/data/apache-pulsar/lib/org.apache.yetus-audience-annotations-0.5.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar:/data/apache-pulsar/lib/org.apache.commons-commons-lang3-3.11.jar:/data/apache-pulsar/lib/org.apache.pulsar-managed-ledger-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-all-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/javax.xml.bind-jaxb-api-2.3.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-api-12.0.1.jar:/data/apache-pulsar/lib/net.jcip-jcip-annotations-1.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-classes-2.0.46.Final.jar:/data/apache-pulsar/lib/org.apache.avro-avro-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-api-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-core-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-local-runner-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-impl-4.14.2.jar:/data/apache-pulsar/lib/com.google.api.grpc-proto-google-common-protos-1.17.0.jar:/data/apache-pulsar/lib/io.perfmark-perfmark-api-0.19.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-proto-4.14.2.jar:/data/apache-pulsar/lib/javax.ws.rs-javax.ws.rs-api-2.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-base-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-proto-0.2.0.jar:/data/apache-pulsar/lib/com.typesafe.netty-netty-reactive-streams-2.0.4.jar:/data/apache-pulsar/lib/io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-sketches-core-0.8.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_hotspot-0.5.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-boringssl-static-2.0.46.Final.jar:/data/apache-pulsar/lib/org.slf4j-jcl-over-slf4j-1.7.25.jar:/data/apache-pulsar/lib/javax.annotation-javax.annotation-api-1.3.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.12.3.jar:/data/apache-pulsar/lib/jline-jline-2.14.6.jar:/data/apache-pulsar/lib/org.apache.avro-avro-protobuf-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-common-2.9.1.jar:/data/apache-pulsar/lib/com.github.ben-manes.caffeine-caffeine-2.9.1.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-impl-0.11.1.jar:/data/apache-pulsar/lib/io.netty-netty-codec-4.1.72.Final.jar:/data/apache-pulsar/lib
2022-02-15T20:07:57,539+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2022-02-15T20:07:57,539+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.io.tmpdir=/tmp
2022-02-15T20:07:57,540+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.compiler=
2022-02-15T20:07:57,541+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.name=Linux
2022-02-15T20:07:57,542+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.arch=amd64
2022-02-15T20:07:57,542+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.version=5.4.172-90.336.amzn2.x86_64
2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.name=root
2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.home=/root
2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.dir=/data/apache-pulsar
2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.free=1874MB
2022-02-15T20:07:57,544+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.max=2048MB
2022-02-15T20:07:57,544+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.total=2048MB
2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.enableEagerACLCheck = false
2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.digest.enabled = true
2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.closeSessionTxn.enabled = true
2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.flushDelay=0
2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.maxWriteQueuePollTime=0
2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.maxBatchSize=1000
2022-02-15T20:07:57,547+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.intBufferStartingSizeBytes = 1024
2022-02-15T20:07:57,550+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - zookeeper.snapshot.trust.empty : true
2022-02-15T20:07:57,740+0000 [main] INFO org.apache.zookeeper.server.watch.WatchManagerFactory - Using org.apache.zookeeper.server.watch.WatchManager as watch manager
2022-02-15T20:07:57,740+0000 [main] INFO org.apache.zookeeper.server.watch.WatchManagerFactory - Using org.apache.zookeeper.server.watch.WatchManager as watch manager
2022-02-15T20:07:57,742+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - zookeeper.snapshotSizeFactor = 0.33
2022-02-15T20:07:57,742+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - zookeeper.commitLogCount=500
2022-02-15T20:07:57,746+0000 [main] INFO org.apache.zookeeper.server.BlueThrottle - Weighed connection throttling is disabled
2022-02-15T20:07:57,748+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - minSessionTimeout set to 6000
2022-02-15T20:07:57,748+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - maxSessionTimeout set to 60000
2022-02-15T20:07:57,750+0000 [main] INFO org.apache.zookeeper.server.ResponseCache - Response cache size is initialized with value 400.
2022-02-15T20:07:57,750+0000 [main] INFO org.apache.zookeeper.server.ResponseCache - Response cache size is initialized with value 400.
2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.slotCapacity = 60
2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.slotDuration = 15
2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.maxDepth = 6
2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.initialDelay = 5
2022-02-15T20:07:57,752+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.delay = 5
2022-02-15T20:07:57,752+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.enabled = false
2022-02-15T20:07:57,841+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - The max bytes for all large requests are set to 104857600
2022-02-15T20:07:57,841+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - The large request threshold is set to -1
2022-02-15T20:07:57,842+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Created server with tickTime 3000 minSessionTimeout 6000 maxSessionTimeout 60000 clientPortListenBacklog -1 datadir data/standalone/zookeeper/version-2 snapdir data/standalone/zookeeper/version-2
2022-02-15T20:07:57,851+0000 [main] WARN org.apache.zookeeper.server.ServerCnxnFactory - maxCnxns is not configured, using default value 0.
2022-02-15T20:07:57,852+0000 [main] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - Configuring NIO connection handler with 10s sessionless connection timeout, 1 selector thread(s), 2 worker threads, and 64 kB direct buffers.
2022-02-15T20:07:57,940+0000 [main] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2181
2022-02-15T20:07:57,948+0000 [main] INFO org.apache.zookeeper.server.persistence.SnapStream - zookeeper.snapshot.compression.method = CHECKED
2022-02-15T20:07:57,949+0000 [main] INFO org.apache.zookeeper.server.persistence.FileSnap - Reading snapshot data/standalone/zookeeper/version-2/snapshot.187
2022-02-15T20:07:58,052+0000 [main] INFO org.apache.zookeeper.server.DataTree - The digest in the snapshot has digest version of 2, , with zxid as 0x187, and digest value as 755870435808
2022-02-15T20:07:58,449+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - 2 txns loaded in 3 ms
2022-02-15T20:07:58,450+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - Snapshot loaded in 506 ms, highest zxid is 0x189, digest is 755870435808
2022-02-15T20:07:58,450+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - Snapshotting: 0x189 to data/standalone/zookeeper/version-2/snapshot.189
2022-02-15T20:07:58,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Snapshot taken in 96 ms
2022-02-15T20:07:58,673+0000 [ProcessThread(sid:0 cport:2181):] INFO org.apache.zookeeper.server.PrepRequestProcessor - PrepRequestProcessor (sid:0) started, reconfigEnabled=false
2022-02-15T20:07:58,739+0000 [main] INFO org.apache.zookeeper.server.RequestThrottler - zookeeper.request_throttler.shutdownTimeout = 10000
2022-02-15T20:07:58,847+0000 [main] INFO org.apache.zookeeper.server.DatadirCleanupManager - autopurge.snapRetainCount set to 3
2022-02-15T20:07:58,939+0000 [main] INFO org.apache.zookeeper.server.DatadirCleanupManager - autopurge.purgeInterval set to 1
2022-02-15T20:07:59,040+0000 [PurgeTask] INFO org.apache.zookeeper.server.DatadirCleanupManager - Purge task started.
2022-02-15T20:07:59,048+0000 [PurgeTask] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - zookeeper.snapshot.trust.empty : true
2022-02-15T20:07:59,050+0000 [PurgeTask] INFO org.apache.zookeeper.server.DatadirCleanupManager - Purge task completed.
2022-02-15T20:07:59,139+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.FourLetterCommands - The list of known four letter word commands is : [{1936881266=srvr, 1937006964=stat, 2003003491=wchc, 1685417328=dump, 1668445044=crst, 1936880500=srst, 1701738089=envi, 1668247142=conf, -720899=telnet close, 1751217000=hash, 2003003507=wchs, 2003003504=wchp, 1684632179=dirs, 1668247155=cons, 1835955314=mntr, 1769173615=isro, 1920298859=ruok, 1735683435=gtmk, 1937010027=stmk}]
2022-02-15T20:07:59,141+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.FourLetterCommands - The list of enabled four letter word commands is : [[wchs, stat, wchp, dirs, stmk, conf, ruok, mntr, srvr, wchc, envi, srst, isro, dump, gtmk, telnet close, crst, hash, cons]]
2022-02-15T20:07:59,141+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.NIOServerCnxn - Processing stat command from /127.0.0.1:41090
2022-02-15T20:07:59,148+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.AbstractFourLetterCommand - Stat command output
2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Server UP
2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - ZooKeeper server up: true
2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Instantiate ZK Client
2022-02-15T20:07:59,241+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT
2022-02-15T20:07:59,241+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local
2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_312
2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Private Build
2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/data/apache-pulsar/conf:::/data/apache-pulsar/lib/com.google.guava-failureaccess-1.0.1.jar:/data/apache-pulsar/lib/io.vertx-vertx-bridge-common-3.9.8.jar:/data/apache-pulsar/lib/org.jctools-jctools-core-2.1.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-socks-4.1.72.Final.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-graphite-3.2.5.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2.jar:/data/apache-pulsar/lib/com.google.code.gson-gson-2.8.6.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-jute-3.6.3.jar:/data/apache-pulsar/lib/jakarta.validation-jakarta.validation-api-2.0.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-haproxy-4.1.72.Final.jar:/data/apache-pulsar/lib/commons-configuration-commons-configuration-1.10.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-common-4.14.2.jar:/data/apache-pulsar/lib/jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar:/data/apache-pulsar/lib/org.reactivestreams-reactive-streams-1.0.3.jar:/data/apache-pulsar/lib/io.gsonfire-gson-fire-1.8.5.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-security-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-common-2.9.1.jar:/data/apache-pulsar/lib/org.apache.thrift-libthrift-0.14.2.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-utils-2.6.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-1.33.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-core-2.12.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient-0.5.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_httpserver-0.5.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.xerial.snappy-snappy-java-1.1.7.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-vertx-http-server-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.checkerframework-checker-qual-3.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-worker-2.9.1.jar:/data/apache-pulsar/lib/io.netty-netty-handler-proxy-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-prometheus-metrics-3.6.3.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-1.2-api-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-runtime-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2-osgi-resource-locator-1.0.3.jar:/data/apache-pulsar/lib/io.grpc-grpc-stub-1.33.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_jetty-0.5.0.jar:/data/apache-pulsar/lib/com.github.zafarkhaja-java-semver-0.9.0.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-web-2.16.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-recipes-5.1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-core-1.6.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-xds-1.33.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar:/data/apache-pulsar/lib/com.squareup.okio-okio-2.8.0.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-locator-2.6.1.jar:/data/apache-pulsar/lib/com.google.re2j-re2j-1.2.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-client-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-auth-1.33.0.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-1.33.0.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-common-3.9.8.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-statelib-4.14.2.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_log4j2-0.5.0.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpclient-4.5.13.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-tools-framework-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-databind-2.12.3.jar:/data/apache-pulsar/lib/org.bitbucket.b_c-jose4j-0.7.6.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-common-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-core-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-original-2.9.1.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-jvm-3.2.5.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-server-4.14.2.jar:/data/apache-pulsar/lib/org.jvnet.mimepull-mimepull-1.9.13.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-multipart-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-testclient-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-shaded-1.33.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-api-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-3.6.3.jar:/data/apache-pulsar/lib/commons-codec-commons-codec-1.15.jar:/data/apache-pulsar/lib/io.netty-netty-codec-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-jackson-0.11.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-tools-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar:/data/apache-pulsar/lib/org.apache.curator-curator-framework-5.1.0.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-memory-0.8.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-secrets-2.9.1.jar:/data/apache-pulsar/lib/com.google.code.findbugs-jsr305-3.0.2.jar:/data/apache-pulsar/lib/io.airlift-aircompressor-0.20.jar:/data/apache-pulsar/lib/com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-prometheus-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcpkix-jdk15on-1.69.jar:/data/apache-pulsar/lib/com.google.auto.value-auto-value-annotations-1.7.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-proto-2.9.1.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-contrib-http-util-0.24.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-server-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-config-validation-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-testmocks-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-utils-2.9.1.jar:/data/apache-pulsar/lib/jakarta.annotation-jakarta.annotation-api-1.3.5.jar:/data/apache-pulsar/lib/jakarta.activation-jakarta.activation-api-1.2.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.12.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-common-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-core-2.9.1.jar:/data/apache-pulsar/lib/javax.servlet-javax.servlet-api-3.1.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.4.32.jar:/data/apache-pulsar/lib/io.vertx-vertx-auth-common-3.9.8.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-1.34.0.jar:/data/apache-pulsar/lib/org.jetbrains-annotations-13.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-bookkeeper-storage-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-slf4j-impl-2.16.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-common-1.4.32.jar:/data/apache-pulsar/lib/io.prometheus.jmx-collector-0.14.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-http-server-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-lite-1.33.0.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-ext-jdk15on-1.69.jar:/data/apache-pulsar/lib/commons-collections-commons-collections-3.2.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-http-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.carrotsearch-hppc-0.7.3.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.12.3.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-1.4.32.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-bookkeeper-stats-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-protocol-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-grpclb-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http-4.1.72.Final.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-api-2.6.1.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.netty-netty-handler-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-buffer-4.1.72.Final.jar:/data/apache-pulsar/lib/com.beust-jcommander-1.78.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-proxy-2.9.1.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-okhttp-4.9.3.jar:/data/apache-pulsar/lib/org.slf4j-slf4j-api-1.7.25.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-common-2.9.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jsonSchema-2.12.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-coordinator-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlets-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_caffeine-0.5.0.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-logging-interceptor-4.9.3.jar:/data/apache-pulsar/lib/org.javassist-javassist-3.25.0-GA.jar:/data/apache-pulsar/lib/org.apache.commons-commons-collections4-4.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-common-4.14.2.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-2.12.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-annotations-2.12.3.jar:/data/apache-pulsar/lib/com.google.errorprone-error_prone_annotations-2.5.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-jakarta.inject-2.6.1.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_servlet-0.5.0.jar:/data/apache-pulsar/lib/javax.websocket-javax.websocket-client-api-1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-models-1.6.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-metadata-2.9.1.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-util-3.11.4.jar:/data/apache-pulsar/lib/io.grpc-grpc-api-1.33.0.jar:/data/apache-pulsar/lib/net.jodah-typetools-0.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/commons-lang-commons-lang-2.6.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-jackson2-1.34.0.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-core-3.2.5.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-3.9.8.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-api-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-proto-12.0.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-proto-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcutil-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpcore-4.4.13.jar:/data/apache-pulsar/lib/io.grpc-grpc-alts-1.33.0.jar:/data/apache-pulsar/lib/javax.validation-validation-api-1.1.0.Final.jar:/data/apache-pulsar/lib/io.netty-netty-common-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_common-0.5.0.jar:/data/apache-pulsar/lib/org.slf4j-jul-to-slf4j-1.7.25.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-api-2.16.0.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-continuation-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar:/data/apache-pulsar/lib/io.swagger-swagger-annotations-1.6.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-proxy-9.4.43.v20210629.jar:/data/apache-pulsar/lib/commons-io-commons-io-2.8.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-codahale-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-api-0.11.1.jar:/data/apache-pulsar/lib/org.hdrhistogram-HdrHistogram-2.1.9.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-io-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.sun.activation-javax.activation-1.2.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-ajax-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-messagecrypto-bc-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-circe-checksum-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-api-2.9.1.jar:/data/apache-pulsar/lib/net.java.dev.jna-jna-4.2.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-common-2.34.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-core-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-websocket-2.9.1.jar:/data/apache-pulsar/lib/commons-logging-commons-logging-1.1.1.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-credentials-0.20.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-client-5.1.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.12.3.jar:/data/apache-pulsar/lib/io.vertx-vertx-core-3.9.8.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-allocator-4.14.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-cpu-affinity-4.14.2.jar:/data/apache-pulsar/lib/commons-cli-commons-cli-1.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-server-4.14.2.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:/data/apache-pulsar/lib/com.google.j2objc-j2objc-annotations-1.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-api-4.14.2.jar:/data/apache-pulsar/lib/com.google.guava-guava-30.1-jre.jar:/data/apache-pulsar/lib/org.glassfish.jersey.inject-jersey-hk2-2.34.jar:/data/apache-pulsar/lib/org.yaml-snakeyaml-1.27.jar:/data/apache-pulsar/lib/io.grpc-grpc-context-1.33.0.jar:/data/apache-pulsar/lib/org.rocksdb-rocksdbjni-6.10.2.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk7-1.4.32.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-oauth2-http-0.20.0.jar:/data/apache-pulsar/lib/org.apache.commons-commons-compress-1.21.jar:/data/apache-pulsar/lib/jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2-tests.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http2-4.1.72.Final.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-api-0.18.0.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-3.11.4.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-services-1.33.0.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-12.0.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-bouncy-castle-bc-2.9.1-pkg.jar:/data/apache-pulsar/lib/org.apache.yetus-audience-annotations-0.5.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar:/data/apache-pulsar/lib/org.apache.commons-commons-lang3-3.11.jar:/data/apache-pulsar/lib/org.apache.pulsar-managed-ledger-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-all-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/javax.xml.bind-jaxb-api-2.3.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-api-12.0.1.jar:/data/apache-pulsar/lib/net.jcip-jcip-annotations-1.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-classes-2.0.46.Final.jar:/data/apache-pulsar/lib/org.apache.avro-avro-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-api-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-core-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-local-runner-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-impl-4.14.2.jar:/data/apache-pulsar/lib/com.google.api.grpc-proto-google-common-protos-1.17.0.jar:/data/apache-pulsar/lib/io.perfmark-perfmark-api-0.19.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-proto-4.14.2.jar:/data/apache-pulsar/lib/javax.ws.rs-javax.ws.rs-api-2.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-base-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-proto-0.2.0.jar:/data/apache-pulsar/lib/com.typesafe.netty-netty-reactive-streams-2.0.4.jar:/data/apache-pulsar/lib/io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-sketches-core-0.8.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_hotspot-0.5.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-boringssl-static-2.0.46.Final.jar:/data/apache-pulsar/lib/org.slf4j-jcl-over-slf4j-1.7.25.jar:/data/apache-pulsar/lib/javax.annotation-javax.annotation-api-1.3.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.12.3.jar:/data/apache-pulsar/lib/jline-jline-2.14.6.jar:/data/apache-pulsar/lib/org.apache.avro-avro-protobuf-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-common-2.9.1.jar:/data/apache-pulsar/lib/com.github.ben-manes.caffeine-caffeine-2.9.1.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-impl-0.11.1.jar:/data/apache-pulsar/lib/io.netty-netty-codec-4.1.72.Final.jar:/data/apache-pulsar/lib
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=5.4.172-90.336.amzn2.x86_64
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=root
2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/root
2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/data/apache-pulsar
2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=1858MB
2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=2048MB
2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=2048MB
2022-02-15T20:07:59,248+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=5000 watcher=org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble$ZKConnectionWatcher@63787180
2022-02-15T20:07:59,252+0000 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
2022-02-15T20:07:59,255+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:07:59,345+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:07:59,444+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:07:59,444+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:07:59,445+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41092, server: localhost/127.0.0.1:2181
2022-02-15T20:07:59,552+0000 [SyncThread:0] INFO org.apache.zookeeper.server.persistence.FileTxnLog - Creating new log file: log.18a
2022-02-15T20:07:59,641+0000 [SyncThread:0] INFO org.apache.zookeeper.audit.ZKAuditProvider - ZooKeeper audit is disabled.
2022-02-15T20:07:59,739+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60000, negotiated timeout = 6000
2022-02-15T20:07:59,844+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Starting Bookie(s)
2022-02-15T20:08:06,846+0000 [main] INFO org.apache.bookkeeper.proto.BookieServer - {
"loadBalancerNamespaceBundleMaxBandwidthMbytes" : "100",
"numExecutorThreadPoolSize" : "",
"exposeTopicLevelMetricsInPrometheus" : "true",
"tlsCertificateFilePath" : "",
"managedLedgerCursorBackloggedThreshold" : "1000",
"exposePreciseBacklogInPrometheus" : "false",
"brokerPublisherThrottlingMaxByteRate" : "0",
"bookkeeperClientHealthCheckErrorThresholdPerInterval" : "5",
"brokerDeduplicationEntriesInterval" : "1000",
"authenticateOriginalAuthData" : "false",
"anonymousUserRole" : "",
"bookkeeperClientNumWorkerThreads" : "",
"dbStorage_rocksDB_numLevels" : "-1",
"packagesManagementStorageProvider" : "org.apache.pulsar.packages.management.storage.bookkeeper.BookKeeperPackagesStorageProvider",
"managedLedgerDigestType" : "CRC32C",
"loadBalancerAutoBundleSplitEnabled" : "true",
"tokenSecretKey" : "",
"bookkeeperClientAuthenticationParametersName" : "",
"managedLedgerDefaultAckQuorum" : "1",
"loadBalancerBrokerThresholdShedderPercentage" : "10",
"forceDeleteNamespaceAllowed" : "false",
"tlsRequireTrustedClientCertOnConnect" : "false",
"webSocketConnectionsPerBroker" : "8",
"zkServers" : "127.0.0.1:2181",
"dbStorage_rocksDB_maxSizeInLevel1MB" : "256",
"brokerServicePort" : "6650",
"loadBalancerReportUpdateMaxIntervalMinutes" : "15",
"managedLedgerNumSchedulerThreads" : "4",
"clientLibraryVersionCheckEnabled" : "false",
"tokenAuthClaim" : "",
"bookkeeperClientReorderReadSequenceEnabled" : "false",
"dbStorage_rocksDB_blockCacheSize" : "",
"brokerShutdownTimeoutMs" : "60000",
"maxConsumersPerSubscription" : "0",
"bookkeeperClientEnforceMinNumRacksPerWriteQuorum" : "false",
"tokenAudience" : "",
"maxNumPartitionsPerPartitionedTopic" : "0",
"brokerClientTlsTrustStore" : "",
"tlsEnabled" : "false",
"managedLedgerMinLedgerRolloverTimeMinutes" : "10",
"tlsProvider" : "",
"bookkeeperTLSTrustCertsFilePath" : "",
"transactionCoordinatorEnabled" : "false",
"clusterName" : "standalone",
"superUserRoles" : "",
"authenticationProviders" : "",
"tlsCiphers" : "",
"brokerClientTlsCiphers" : "",
"dispatchThrottlingRateRelativeToPublishRate" : "false",
"haProxyProtocolEnabled" : "false",
"bookkeeperUseV2WireProtocol" : "true",
"bookiePort" : "3181",
"managedLedgerCacheSizeMB" : "",
"maxSameAddressProducersPerTopic" : "0",
"advertisedAddress" : "127.0.0.1",
"bookkeeperClientRegionawarePolicyEnabled" : "false",
"brokerDeduplicationEnabled" : "false",
"topicPublisherThrottlingTickTimeMillis" : "2",
"dispatchThrottlingOnNonBacklogConsumerEnabled" : "true",
"bookkeeperTLSTrustCertTypes" : "PEM",
"webSocketServiceEnabled" : "true",
"bookkeeperTLSCertificateFilePath" : "",
"numHttpServerThreads" : "",
"managedLedgerCacheEvictionWatermark" : "0.9",
"loadBalancerNamespaceBundleMaxMsgRate" : "30000",
"bookkeeperClientHealthCheckIntervalSeconds" : "60",
"webSocketSessionIdleTimeoutMillis" : "300000",
"allowAutoTopicCreationType" : "non-partitioned",
"managedLedgerMaxSizePerLedgerMbytes" : "2048",
"exposePublisherStats" : "true",
"tlsKeyStoreType" : "JKS",
"maxUnackedMessagesPerConsumer" : "50000",
"replicationConnectionsPerBroker" : "16",
"bookkeeperTLSTrustStorePasswordPath" : "",
"maxSameAddressConsumersPerTopic" : "0",
"managedLedgerMetadataOperationsTimeoutSeconds" : "60",
"webServicePort" : "8080",
"ledgerStorageClass" : "org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage",
"gcWaitTime" : "300000",
"maxConcurrentHttpRequests" : "1024",
"enableNonPersistentTopics" : "true",
"managedLedgerPrometheusStatsLatencyRolloverSeconds" : "60",
"loadBalancerNamespaceBundleMaxTopics" : "1000",
"brokerClientTlsTrustStorePassword" : "",
"managedLedgerCursorMaxEntriesPerLedger" : "50000",
"brokerClientAuthenticationPlugin" : "",
"loadBalancerMemoryResourceWeight" : "1.0",
"bookkeeperClientMinAvailableBookiesInIsolationGroups" : "",
"athenzDomainNames" : "",
"dbStorage_rocksDB_writeBufferSizeMB" : "4",
"proxyRoles" : "",
"managedLedgerNumWorkerThreads" : "4",
"loadBalancerReportUpdateThresholdPercentage" : "10",
"dbStorage_rocksDB_sstSizeInMB" : "4",
"brokerDeleteInactiveTopicsEnabled" : "true",
"diskUsageThreshold" : "0.99",
"bookkeeperClientRackawarePolicyEnabled" : "true",
"managedLedgerMaxUnackedRangesToPersist" : "10000",
"maxConcurrentTopicLoadRequest" : "5000",
"enablePersistentTopics" : "true",
"managedLedgerTraceTaskExecution" : "true",
"loadBalancerAutoUnloadSplitBundlesEnabled" : "true",
"dbStorage_rocksDB_blockSize" : "4096",
"encryptionRequireOnProducer" : "false",
"zooKeeperOperationTimeoutSeconds" : "30",
"maxPendingPublishRequestsPerConnection" : "1000",
"bookkeeperTLSKeyFilePath" : "",
"allowLoopback" : "true",
"webSocketMaxTextFrameSize" : "1048576",
"loadBalancerCPUResourceWeight" : "1.0",
"backlogQuotaCheckEnabled" : "true",
"replicationPolicyCheckDurationSeconds" : "600",
"allowAutoTopicCreation" : "true",
"bookkeeperClientIsolationGroups" : "",
"configurationStoreServers" : "",
"maxUnackedMessagesPerSubscriptionOnBrokerBlocked" : "0.16",
"dbStorage_writeCacheMaxSizeMb" : "",
"brokerClientTlsProtocols" : "",
"authorizationEnabled" : "false",
"loadBalancerSheddingIntervalMinutes" : "1",
"managedLedgerCursorPositionFlushSeconds" : "60",
"loadManagerClassName" : "org.apache.pulsar.broker.loadbalance.NoopLoadManager",
"bookkeeperClientHealthCheckQuarantineTimeInSeconds" : "1800",
"numCacheExecutorThreadPoolSize" : "10",
"loadBalancerSheddingGracePeriodMinutes" : "30",
"backlogQuotaCheckIntervalInSeconds" : "60",
"loadBalancerBandwithInResourceWeight" : "1.0",
"loadBalancerBandwithOutResourceWeight" : "1.0",
"bookkeeperClientTimeoutInSeconds" : "30",
"tlsTrustCertsFilePath" : "",
"managedLedgerCacheEvictionFrequency" : "100.0",
"autoSkipNonRecoverableData" : "false",
"bookkeeperClientHealthCheckEnabled" : "true",
"dbStorage_rocksDB_numFilesInLevel0" : "4",
"brokerDeleteInactiveTopicsFrequencySeconds" : "60",
"managedLedgerReadEntryTimeoutSeconds" : "0",
"loadBalancerBrokerMaxTopics" : "50000",
"nettyMaxFrameSizeBytes" : "5253120",
"enablePackagesManagement" : "false",
"managedLedgerAddEntryTimeoutSeconds" : "0",
"loadBalancerDirectMemoryResourceWeight" : "1.0",
"managedLedgerMaxEntriesPerLedger" : "50000",
"loadBalancerNamespaceMaximumBundles" : "128",
"managedLedgerCacheCopyEntries" : "false",
"tlsCertRefreshCheckDurationSec" : "300",
"journalSyncData" : "false",
"bindAddress" : "0.0.0.0",
"transactionMetadataStoreProviderClassName" : "org.apache.pulsar.transaction.coordinator.impl.MLTransactionMetadataStoreProvider",
"tlsAllowInsecureConnection" : "false",
"allowEphemeralPorts" : "true",
"maxProducersPerTopic" : "0",
"tokenPublicKey" : "",
"subscriptionExpirationTimeMinutes" : "0",
"numWorkerThreadsForNonPersistentTopic" : "8",
"maxConcurrentNonPersistentMessagePerConnection" : "1000",
"managedLedgerNewEntriesCheckDelayInMillis" : "10",
"bookkeeperClientAuthenticationParameters" : "",
"authenticationEnabled" : "false",
"numIOThreads" : "",
"maxSubscriptionsPerTopic" : "0",
"maxTopicsPerNamespace" : "0",
"allocatorPoolingPolicy" : "UnpooledHeap",
"topicLevelPoliciesEnabled" : "false",
"brokerClientTlsEnabledWithKeyStore" : "false",
"maxConsumersPerTopic" : "0",
"brokerClientTlsTrustStoreType" : "JKS",
"backlogQuotaDefaultLimitSecond" : "-1",
"bookkeeperClientMinNumRacksPerWriteQuorum" : "1",
"numOrderedExecutorThreads" : "8",
"subscriptionRedeliveryTrackerEnabled" : "true",
"dispatchThrottlingRatePerTopicInByte" : "0",
"managedLedgerCursorRolloverTimeInSeconds" : "14400",
"globalZookeeperServers" : "",
"defaultNumberOfNamespaceBundles" : "4",
"loadBalancerEnabled" : "false",
"dbStorage_readAheadCacheMaxSizeMb" : "",
"activeConsumerFailoverDelayTimeMillis" : "1000",
"managedLedgerDefaultEnsembleSize" : "1",
"loadBalancerHistoryResourcePercentage" : "0.9",
"dbStorage_readAheadCacheBatchSize" : "1000",
"bindAddresses" : "",
"authorizationProvider" : "org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider",
"tlsTrustStore" : "",
"maxMessageSizeCheckIntervalInSeconds" : "60",
"zookeeperServers" : "",
"transactionBufferSnapshotMaxTransactionCount" : "1000",
"defaultRetentionSizeInMB" : "0",
"defaultNumPartitions" : "1",
"packagesReplicas" : "1",
"topicFencingTimeoutSeconds" : "0",
"bookkeeperTLSProviderFactoryClass" : "org.apache.bookkeeper.tls.TLSContextFactory",
"bookkeeperNumberOfChannelsPerBookie" : "16",
"transactionBufferSnapshotMinTimeInMillis" : "5000",
"brokerClientSslProvider" : "",
"preciseDispatcherFlowControl" : "false",
"maxConcurrentLookupRequest" : "50000",
"skipBrokerShutdownOnOOM" : "false",
"bookkeeperTLSKeyStorePasswordPath" : "",
"defaultRetentionTimeInMinutes" : "0",
"brokerPublisherThrottlingMaxMessageRate" : "0",
"bookkeeperExplicitLacIntervalInMills" : "0",
"replicationProducerQueueSize" : "1000",
"loadBalancerNamespaceBundleMaxSessions" : "1000",
"tlsProtocols" : "",
"managedLedgerDefaultWriteQuorum" : "1",
"zooKeeperSessionTimeoutMillis" : "30000",
"statusFilePath" : "/usr/local/apache/htdocs",
"bookkeeperClientSecondaryIsolationGroups" : "",
"tokenAudienceClaim" : "",
"brokerServicePurgeInactiveFrequencyInSeconds" : "60",
"journalMaxGroupWaitMSec" : "1",
"dbStorage_rocksDB_bloomFilterBitsPerKey" : "10",
"brokerDeduplicationMaxNumberOfProducers" : "10000",
"diskUsageWarnThreshold" : "0.99",
"brokerDeduplicationProducerInactivityTimeoutMinutes" : "360",
"tlsKeyFilePath" : "",
"bookkeeperClientAuthenticationPlugin" : "",
"packagesManagementLedgerRootPath" : "/ledgers",
"bookkeeperDiskWeightBasedPlacementEnabled" : "false",
"tlsTrustStoreType" : "JKS",
"authorizationAllowWildcardsMatching" : "false",
"subscriptionKeySharedConsistentHashingReplicaPoints" : "100",
"managedLedgerDefaultMarkDeleteRateLimit" : "0.1",
"bookkeeperClientQuarantineRatio" : "1.0",
"managedLedgerMaxLedgerRolloverTimeMinutes" : "240",
"subscriptionExpiryCheckIntervalInMinutes" : "5",
"maxUnackedMessagesPerBroker" : "0",
"preciseTopicPublishRateLimiterEnable" : "false",
"tlsKeyStore" : "",
"keepAliveIntervalSeconds" : "30",
"flushInterval" : "60000",
"brokerClientAuthenticationParameters" : "",
"splitTopicAndPartitionLabelInPrometheus" : "false",
"tlsEnabledWithKeyStore" : "false",
"managedLedgerCacheEvictionTimeThresholdMillis" : "1000",
"replicationMetricsEnabled" : "true",
"bookkeeperClientSpeculativeReadTimeoutInMillis" : "0",
"bookkeeperTLSKeyFileType" : "PEM",
"ttlDurationDefaultInSeconds" : "0",
"backlogQuotaDefaultLimitGB" : "10",
"ledgerDirectories" : "data/standalone/bookkeeper0",
"zooKeeperCacheExpirySeconds" : "300",
"journalDirectories" : "data/standalone/bookkeeper0",
"bookkeeperTLSClientAuthentication" : "false",
"managedLedgerMaxUnackedRangesToPersistInZooKeeper" : "1000",
"loadBalancerBundleUnloadMinThroughputThreshold" : "10",
"metricsServletTimeoutMs" : "30000",
"dispatchThrottlingRatePerTopicInMsg" : "0",
"maxUnackedMessagesPerSubscription" : "200000",
"tlsTrustStorePassword" : "",
"failureDomainsEnabled" : "false",
"managedLedgerUnackedRangesOpenCacheSetEnabled" : "true",
"forceDeleteTenantAllowed" : "false",
"webSocketNumIoThreads" : "8",
"subscriptionKeySharedUseConsistentHashing" : "false",
"brokerPublisherThrottlingTickTimeMillis" : "50",
"tlsKeyStorePassword" : "",
"systemTopicEnabled" : "false",
"allowAutoSubscriptionCreation" : "true",
"messageExpiryCheckIntervalInMinutes" : "5",
"loadBalancerHostUsageCheckIntervalMinutes" : "1",
"loadBalancerResourceQuotaUpdateIntervalMinutes" : "15"
}
2022-02-15T20:08:07,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053c2ea580000, timeout of 6000ms exceeded
2022-02-15T20:08:08,442+0000 [main] INFO org.apache.bookkeeper.proto.BookieNettyServer - Binding bookie-rpc endpoint to 0.0.0.0/0.0.0.0:3181
2022-02-15T20:08:09,139+0000 [main] INFO org.apache.bookkeeper.meta.MetadataDrivers - BookKeeper metadata driver manager initialized
2022-02-15T20:08:09,150+0000 [main] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver at metadata service uri zk+null://127.0.0.1:2181/ledgers : zkServers = 127.0.0.1:2181, ledgersRootPath = /ledgers.
2022-02-15T20:08:09,153+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@71984c3
2022-02-15T20:08:09,239+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:09,240+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:09,241+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:09,242+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:09,243+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41130, server: localhost/127.0.0.1:2181
2022-02-15T20:08:09,246+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60001, negotiated timeout = 10000
2022-02-15T20:08:09,339+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
2022-02-15T20:08:09,358+0000 [main] INFO org.apache.bookkeeper.discover.ZKRegistrationManager - INSTANCEID not exists in zookeeper. Not considering it for data verification
2022-02-15T20:08:10,242+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - instantiate ledger manager org.apache.bookkeeper.meta.HierarchicalLedgerManagerFactory
2022-02-15T20:08:10,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000b, timeout of 10000ms exceeded
2022-02-15T20:08:10,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0001, timeout of 10000ms exceeded
2022-02-15T20:08:10,341+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0007, timeout of 10000ms exceeded
2022-02-15T20:08:10,342+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000a, timeout of 10000ms exceeded
2022-02-15T20:08:10,350+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Using ledger storage: org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage
2022-02-15T20:08:10,439+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - Started Db Ledger Storage
2022-02-15T20:08:10,439+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Number of directories: 1
2022-02-15T20:08:10,440+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Write cache size: 1024 MB
2022-02-15T20:08:10,440+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Read Cache: 1024 MB
2022-02-15T20:08:10,443+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.SingleDirectoryDbLedgerStorage - Creating single directory db ledger storage on data/standalone/bookkeeper0/current
2022-02-15T20:08:11,348+0000 [main] INFO org.apache.bookkeeper.bookie.ScanAndCompareGarbageCollector - Over Replicated Ledger Deletion : enabled=true, interval=86400000
2022-02-15T20:08:11,444+0000 [main] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Minor Compaction : enabled=true, threshold=0.20000000298023224, interval=3600000
2022-02-15T20:08:11,444+0000 [main] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Major Compaction : enabled=true, threshold=0.800000011920929, interval=86400000
2022-02-15T20:08:11,654+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Replaying journal 1644953547840 from position 61440
2022-02-15T20:08:11,742+0000 [main] INFO org.apache.bookkeeper.bookie.JournalChannel - Opening journal data/standalone/bookkeeper0/current/17efedf3440.txn
2022-02-15T20:08:11,747+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Finished replaying journal in 94 ms.
2022-02-15T20:08:11,753+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.EntryLogManagerBase - Creating a new entry log file because current active log channel has not initialized yet
2022-02-15T20:08:11,756+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Created new entry log file data/standalone/bookkeeper0/current/2.log for logId 2.
2022-02-15T20:08:11,840+0000 [pool-6-thread-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Created new entry log file data/standalone/bookkeeper0/current/3.log for logId 3.
2022-02-15T20:08:11,859+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.SyncThread - Flush ledger storage at checkpoint CheckpointList{checkpoints=[LogMark: logFileId - 1644953547840 , logFileOffset - 62468]}.
2022-02-15T20:08:11,861+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Finished reading journal, starting bookie
2022-02-15T20:08:11,940+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Starting journal on data/standalone/bookkeeper0/current
2022-02-15T20:08:11,942+0000 [ForceWriteThread] INFO org.apache.bookkeeper.bookie.Journal - ForceWrite Thread started
2022-02-15T20:08:11,943+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.JournalChannel - Opening journal data/standalone/bookkeeper0/current/17efedf3441.txn
2022-02-15T20:08:12,600+0000 [main] WARN org.apache.curator.retry.ExponentialBackoffRetry - maxRetries too large (2147483647). Pinning to 29
2022-02-15T20:08:13,053+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2022-02-15T20:08:13,141+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=60000 watcher=org.apache.curator.ConnectionState@40147317
2022-02-15T20:08:13,142+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:13,143+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:13,144+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:13,145+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:13,145+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41158, server: localhost/127.0.0.1:2181
2022-02-15T20:08:13,242+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60002, negotiated timeout = 60000
2022-02-15T20:08:13,342+0000 [main-EventThread] INFO org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2022-02-15T20:08:13,345+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2022-02-15T20:08:13,350+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2022-02-15T20:08:13,443+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2022-02-15T20:08:13,742+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.cluster.ZkClusterInitializer - Loaded cluster metadata :
num_storage_containers: 2

2022-02-15T20:08:13,743+0000 [Curator-Framework-0] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2022-02-15T20:08:13,944+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60002.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60002, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:14,052+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60002
2022-02-15T20:08:14,052+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60002 closed
2022-02-15T20:08:14,066+0000 [main] WARN org.apache.bookkeeper.stream.server.StorageServer - Determining hostname for stream storage
2022-02-15T20:08:14,139+0000 [main] WARN org.apache.bookkeeper.stream.server.StorageServer - Decided to use hostname 172.31.24.239
2022-02-15T20:08:14,147+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Dlog configuration : {
"bkcEnsembleSize" : "1",
"bkcWriteQuorumSize" : "1",
"bkcAckQuorumSize" : "1"
}
2022-02-15T20:08:14,148+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Storage configuration : {
"range.store.dirs" : "data/standalone/bookkeeper/ranges/data"
}
2022-02-15T20:08:14,148+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Server configuration : {
"grpc.port" : "4181"
}
2022-02-15T20:08:14,253+0000 [main] WARN org.apache.curator.retry.ExponentialBackoffRetry - maxRetries too large (2147483647). Pinning to 29
2022-02-15T20:08:14,662+0000 [main] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver at metadata service uri zk://127.0.0.1:2181/ledgers : zkServers = 127.0.0.1:2181, ledgersRootPath = /ledgers.
2022-02-15T20:08:14,662+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@77cc6a28
2022-02-15T20:08:14,662+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:14,663+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:14,740+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:14,740+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:14,741+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41162, server: localhost/127.0.0.1:2181
2022-02-15T20:08:14,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60003, negotiated timeout = 10000
2022-02-15T20:08:14,744+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
2022-02-15T20:08:14,853+0000 [main-EventThread] INFO org.apache.bookkeeper.discover.ZKRegistrationClient - Update BookieInfoCache (writable bookie) 127.0.0.1:3181 -> BookieServiceInfo{properties={}, endpoints=[EndpointInfo{id=127.0.0.1:3181, port=3181, host=127.0.0.1, protocol=bookie-rpc, auth=[], extensions=[]}]}
2022-02-15T20:08:14,939+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60003.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60003, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:15,040+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60003 closed
2022-02-15T20:08:15,040+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60003
2022-02-15T20:08:15,041+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=60000 watcher=org.apache.curator.ConnectionState@65262308
2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:15,044+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:15,044+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:15,045+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41164, server: localhost/127.0.0.1:2181
2022-02-15T20:08:15,046+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2022-02-15T20:08:15,052+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60004, negotiated timeout = 60000
2022-02-15T20:08:15,046+0000 [main] INFO org.apache.bookkeeper.stream.server.service.CuratorProviderService - Provided curator clients to zookeeper 127.0.0.1:2181.
2022-02-15T20:08:15,053+0000 [main-EventThread] INFO org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2022-02-15T20:08:15,140+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2022-02-15T20:08:15,142+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2022-02-15T20:08:15,149+0000 [main] INFO org.apache.bookkeeper.stream.server.service.DLNamespaceProviderService - Initializing dlog namespace at distributedlog://127.0.0.1:2181/stream/storage
2022-02-15T20:08:15,242+0000 [main] INFO org.apache.distributedlog.namespace.NamespaceDriverManager - DistributedLog NamespaceDriverManager initialized
2022-02-15T20:08:15,342+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@7ac1b6c0
2022-02-15T20:08:15,342+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:15,343+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:15,344+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:15,344+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:15,345+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41168, server: localhost/127.0.0.1:2181
2022-02-15T20:08:15,350+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60005, negotiated timeout = 30000
2022-02-15T20:08:15,351+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
2022-02-15T20:08:15,441+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Close zookeeper client default.
2022-02-15T20:08:15,441+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closing zookeeper client default.
2022-02-15T20:08:15,544+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60005 closed
2022-02-15T20:08:15,544+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60005
2022-02-15T20:08:15,544+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closed zookeeper client default.
2022-02-15T20:08:15,550+0000 [main] INFO org.apache.distributedlog.api.namespace.NamespaceBuilder - No feature provider is set. All features are disabled now.
2022-02-15T20:08:15,554+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared zooKeeper client builder dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared: zkServers = 127.0.0.1:2181, numRetries = 3, sessionTimeout = 30000, retryBackoff = 5000, maxRetryBackoff = 30000, zkAclId = null.
2022-02-15T20:08:15,556+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@58f97013
2022-02-15T20:08:15,556+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:15,557+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:15,557+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:15,558+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:15,558+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41170, server: localhost/127.0.0.1:2181
2022-02-15T20:08:15,642+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60006, negotiated timeout = 30000
2022-02-15T20:08:15,642+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
2022-02-15T20:08:15,646+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared client builder bk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared : zkServers = 127.0.0.1:2181, ledgersPath = /ledgers, numIOThreads = 1
2022-02-15T20:08:15,649+0000 [main] INFO org.apache.distributedlog.impl.metadata.BKDLConfig - Propagate BKDLConfig to DLConfig : encodeRegionID = false, firstLogSegmentSequenceNumber = 1, createStreamIfNotExists = true, isFederated = false.
2022-02-15T20:08:15,658+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Initialized BK namespace driver: clientId = storage-server, regionId = 0, federated = false.
2022-02-15T20:08:15,758+0000 [main] INFO org.apache.distributedlog.logsegment.LogSegmentMetadataCache - Log segment cache is enabled = true
2022-02-15T20:08:15,839+0000 [main] INFO org.apache.bookkeeper.stream.server.service.DLNamespaceProviderService - Provided distributedlog namespace at distributedlog://127.0.0.1:2181/stream/storage.
2022-02-15T20:08:20,741+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - Client session timed out, have not heard from server in 4397ms for session id 0x10053c489f60000
2022-02-15T20:08:20,742+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x10053c489f60000 for sever localhost/127.0.0.1:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException.
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 4397ms for session id 0x10053c489f60000
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1258) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:20,744+0000 [NIOWorkerThread-1] WARN org.apache.zookeeper.server.NIOServerCnxn - Unexpected exception
org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client, it probably closed the socket: address = /127.0.0.1:41092, session = 0x10053c489f60000
at org.apache.zookeeper.server.NIOServerCnxn.handleFailedRead(NIOServerCnxn.java:163) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:326) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.server.NIOServerCnxnFactory$IOWorkRequest.doWork(NIOServerCnxnFactory.java:522) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.server.WorkerService$ScheduledWorkRequest.run(WorkerService.java:154) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_312]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_312]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312]
2022-02-15T20:08:23,650+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Watched cluster assignment data.
2022-02-15T20:08:23,740+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Scheduled storage container probe task at every 15000 ms
2022-02-15T20:08:23,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:23,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:23,744+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41204, server: localhost/127.0.0.1:2181
2022-02-15T20:08:23,841+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60000, negotiated timeout = 6000
2022-02-15T20:08:24,047+0000 [zk-storage-container-manager] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Servers joined : [hostname: "172.31.29.87"
port: 4181
]
2022-02-15T20:08:24,255+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.grpc.GrpcMetaRangeService - Created MetaRange service
2022-02-15T20:08:24,342+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.grpc.GrpcTableService - Created Table service
2022-02-15T20:08:24,939+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@5f190cfe
2022-02-15T20:08:24,940+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
2022-02-15T20:08:24,940+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false
2022-02-15T20:08:24,949+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181.
2022-02-15T20:08:24,950+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error)
2022-02-15T20:08:24,950+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41212, server: localhost/127.0.0.1:2181
2022-02-15T20:08:25,041+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60007, negotiated timeout = 10000
2022-02-15T20:08:25,041+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
2022-02-15T20:08:25,047+0000 [main] INFO org.apache.bookkeeper.stream.server.service.RegistrationStateService - Successfully register myself under registration path /stream/servers/172.31.24.239:4181
2022-02-15T20:08:25,152+0000 [main] INFO org.apache.bookkeeper.stream.server.service.ClusterControllerService - Successfully started the cluster controller.
2022-02-15T20:08:29,139+0000 [client-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.clients.impl.channel.StorageServerChannelManager - Added range server (hostname: "172.31.29.87"
port: 4181
) into the channel manager.
2022-02-15T20:08:29,340+0000 [client-scheduler-OrderedScheduler-0-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
io.grpc.StatusRuntimeException: UNAVAILABLE: io exception
at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0]
at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0]
at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312]
Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181
Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host
at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
... 1 more
2022-02-15T20:08:30,346+0000 [client-scheduler-OrderedScheduler-1-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
io.grpc.StatusRuntimeException: UNAVAILABLE: io exception
at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0]
at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312]
Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181
Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host
at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
... 1 more
2022-02-15T20:08:31,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0009, timeout of 30000ms exceeded
2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0008, timeout of 30000ms exceeded
2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0006, timeout of 30000ms exceeded
2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000e, timeout of 30000ms exceeded
2022-02-15T20:08:31,341+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000c, timeout of 30000ms exceeded
2022-02-15T20:08:31,969+0000 [client-scheduler-OrderedScheduler-0-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
io.grpc.StatusRuntimeException: UNAVAILABLE: io exception
at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0]
at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312]
Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181
Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host
at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
... 1 more
^C2022-02-15T20:08:33,849+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60007.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60007, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:34,040+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60007
2022-02-15T20:08:34,040+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60007 closed
2022-02-15T20:08:34,042+0000 [Thread-1] INFO org.apache.distributedlog.BookKeeperClient - BookKeeper Client closed bk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared
2022-02-15T20:08:34,043+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Close zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared.
2022-02-15T20:08:34,043+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Closing zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared.
2022-02-15T20:08:34,045+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60006.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60006, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:34,145+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60006
2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60006 closed
2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Closed zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared.
2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Release external resources used by channel factory.
2022-02-15T20:08:34,147+0000 [Thread-1] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Stopped request timer
2022-02-15T20:08:34,148+0000 [Thread-1] INFO org.apache.distributedlog.BKDistributedLogNamespace - Executor Service Stopped.
2022-02-15T20:08:34,148+0000 [Curator-Framework-0] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2022-02-15T20:08:34,155+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60004.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60004, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:34,256+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60004 closed
2022-02-15T20:08:34,257+0000 [Thread-1] INFO org.apache.bookkeeper.proto.BookieServer - Shutting down BookieServer
2022-02-15T20:08:34,257+0000 [Thread-1] INFO org.apache.bookkeeper.proto.BookieNettyServer - Shutting down BookieNettyServer
2022-02-15T20:08:34,258+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60004
2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Bookie - Shutting down Bookie-3181 with exitCode 0
2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Bookie - Turning bookie to read only during shut down
2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.SyncThread - Shutting down SyncThread
2022-02-15T20:08:34,348+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.SyncThread - Flush ledger storage at checkpoint CheckpointList{checkpoints=[LogMark: logFileId - 1644953547840 , logFileOffset - 62468]}.
2022-02-15T20:08:34,351+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Journal - Shutting down Journal
2022-02-15T20:08:34,352+0000 [ForceWriteThread] INFO org.apache.bookkeeper.bookie.Journal - ForceWrite thread interrupted
2022-02-15T20:08:34,352+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Journal exits when shutting down
2022-02-15T20:08:34,353+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Journal exited loop!
2022-02-15T20:08:34,353+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Journal - Finished Shutting down Journal thread
2022-02-15T20:08:34,354+0000 [Bookie-3181] INFO org.apache.bookkeeper.bookie.Bookie - Journal thread(s) quit.
2022-02-15T20:08:34,366+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Shutting down GarbageCollectorThread
2022-02-15T20:08:34,367+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.EntryLogger - Stopping EntryLogger
2022-02-15T20:08:34,367+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Stopped entry logger preallocator.
2022-02-15T20:08:34,369+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.LedgerDirsMonitor - Shutting down LedgerDirsMonitor
2022-02-15T20:08:34,440+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60001.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60001, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:34,463+0000 [client-scheduler-OrderedScheduler-1-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
io.grpc.StatusRuntimeException: UNAVAILABLE: io exception
at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0]
at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312]
Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181
Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host
at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0]
... 1 more
2022-02-15T20:08:34,541+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60001
2022-02-15T20:08:34,542+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60001 closed
2022-02-15T20:08:34,550+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60000.
org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60000, likely server has closed socket
at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3]
2022-02-15T20:08:34,651+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60000
2022-02-15T20:08:34,651+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60000 closed
2022-02-15T20:08:34,652+0000 [Thread-1] INFO org.apache.zookeeper.server.ZooKeeperServer - shutting down
2022-02-15T20:08:34,652+0000 [Thread-1] INFO org.apache.zookeeper.server.RequestThrottler - Shutting down
2022-02-15T20:08:34,652+0000 [RequestThrottler] INFO org.apache.zookeeper.server.RequestThrottler - Draining request throttler queue
2022-02-15T20:08:34,653+0000 [RequestThrottler] INFO org.apache.zookeeper.server.RequestThrottler - RequestThrottler shutdown. Dropped 0 requests
2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.SessionTrackerImpl - Shutting down
2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.PrepRequestProcessor - Shutting down
2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.SyncRequestProcessor - Shutting down
2022-02-15T20:08:34,654+0000 [SyncThread:0] INFO org.apache.zookeeper.server.SyncRequestProcessor - SyncRequestProcessor exited!
2022-02-15T20:08:34,654+0000 [ProcessThread(sid:0 cport:2181):] INFO org.apache.zookeeper.server.PrepRequestProcessor - PrepRequestProcessor exited loop!
2022-02-15T20:08:34,654+0000 [Thread-1] INFO org.apache.zookeeper.server.FinalRequestProcessor - shutdown of request processor complete
2022-02-15T20:08:34,656+0000 [NIOServerCxnFactory.AcceptThread:0.0.0.0/0.0.0.0:2181] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - accept thread exitted run method
2022-02-15T20:08:34,657+0000 [ConnnectionExpirer] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - ConnnectionExpirerThread interrupted
2022-02-15T20:08:34,657+0000 [NIOServerCxnFactory.SelectorThread-0] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - selector thread exitted run method
2022-02-15T20:08:34,660+0000 [Thread-1] INFO org.apache.zookeeper.server.DatadirCleanupManager - Shutting down purge task.`

0 replies

2022-04-15T02:14:39Z

github-actions[bot]
Bot Apr 15, 2022

The issue had no activity for 30 days, mark with Stale label.

0 replies

2022-05-28T02:10:49Z

github-actions[bot]
Bot May 28, 2022

The issue had no activity for 30 days, mark with Stale label.

0 replies

Navigation Menu

Debezium Demo Doesn't Work with 2.9.1 and Aurora 5.x #20101

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 3 comments

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{title}}

Uh oh!

Select a reply

Uh oh!

Debezium Demo Doesn't Work with 2.9.1 and Aurora 5.x #20101

Uh oh!

Uh oh!

prime-minister-of-fun Feb 15, 2022

Replies: 3 comments

Uh oh!

prime-minister-of-fun Feb 15, 2022 Author

Uh oh!

github-actions[bot] Bot Apr 15, 2022

Uh oh!

github-actions[bot] Bot May 28, 2022

prime-minister-of-fun
Feb 15, 2022

prime-minister-of-fun
Feb 15, 2022
Author

github-actions[bot]
Bot Apr 15, 2022

github-actions[bot]
Bot May 28, 2022