Skip to content

Latest commit

 

History

History
402 lines (380 loc) · 17.7 KB

20240528Test.md

File metadata and controls

402 lines (380 loc) · 17.7 KB

Prepare patched jars

netty


# clone netty
https://github.com/netty/netty.git
# checkout
git checkout 4.1
# build
mvn  install -DskipTests
 
# package
mvn -DskipTests package
 
# copy
netty-buffer-4.1.111.Final-SNAPSHOT.jar

bookkeeper

git clone https://github.com/lhotari/bookkeeper
git checkout lh-fix-tls-stability-with-V2-branch-4.16
 
 
 
mvn  install -DskipTests
mvn package -DskipTests
# all in
bookkeeper/bookkeeper-dist/all/target/bookkeeper-all-4.16.6-SNAPSHOT-bin.tar.gz
 
tar xfvz bookkeeper-all-4.16.6-SNAPSHOT-bin.tar.gz
cd bookkeeper-all-4.16.6-SNAPSHOT/lib
tar cfvz bookkeeper.tgz org.apache.bookkeeper*
# copy
cp bookkeeper.tgz

broker

git checkout v3.2.2
git cherry-pick 88f34bba12e9f27c78db2ce468b4d46619a92853
mvn package -DskipTests 
# copy
copy   managed-ledger/target/managed-ledger.jar


Prepare

Jar list

com.auth0-java-jwt-4.3.0.jar
com.auth0-jwks-rsa-0.22.0.jar
com.beust-jcommander-1.82.jar
com.carrotsearch-hppc-0.9.1.jar
com.fasterxml.jackson.core-jackson-annotations-2.14.2.jar
com.fasterxml.jackson.core-jackson-core-2.14.2.jar
com.fasterxml.jackson.core-jackson-databind-2.14.2.jar
com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.14.2.jar
com.fasterxml.jackson.datatype-jackson-datatype-jdk8-2.14.2.jar
com.fasterxml.jackson.datatype-jackson-datatype-jsr310-2.14.2.jar
com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.14.2.jar
com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.14.2.jar
com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.14.2.jar
com.fasterxml.jackson.module-jackson-module-jsonSchema-2.14.2.jar
com.fasterxml.jackson.module-jackson-module-parameter-names-2.14.2.jar
com.github.ben-manes.caffeine-caffeine-2.9.1.jar
com.github.oshi-oshi-core-java11-6.4.0.jar
com.github.seancfoley-ipaddress-5.3.3.jar
com.github.zafarkhaja-java-semver-0.9.0.jar
com.google.api.grpc-proto-google-common-protos-2.9.0.jar
com.google.auth-google-auth-library-credentials-1.4.0.jar
com.google.auth-google-auth-library-oauth2-http-1.4.0.jar
com.google.auto.value-auto-value-annotations-1.9.jar
com.google.code.findbugs-jsr305-3.0.2.jar
com.google.code.gson-gson-2.8.9.jar
com.google.errorprone-error_prone_annotations-2.5.1.jar
com.google.guava-failureaccess-1.0.1.jar
com.google.guava-guava-32.1.2-jre.jar
com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar
com.google.http-client-google-http-client-1.41.0.jar
com.google.http-client-google-http-client-gson-1.41.0.jar
com.google.j2objc-j2objc-annotations-1.3.jar
com.google.protobuf-protobuf-java-util-3.19.6.jar
com.google.re2j-re2j-1.6.jar
commons-cli-commons-cli-1.5.0.jar
commons-codec-commons-codec-1.15.jar
commons-configuration-commons-configuration-1.10.jar
commons-io-commons-io-2.8.0.jar
commons-lang-commons-lang-2.6.jar
commons-logging-commons-logging-1.1.1.jar
com.squareup.okhttp3-logging-interceptor-4.9.3.jar
com.squareup.okhttp3-okhttp-4.9.3.jar
com.squareup.okio-okio-3.4.0.jar
com.squareup.okio-okio-jvm-3.4.0.jar
com.sun.activation-javax.activation-1.2.0.jar
com.typesafe.netty-netty-reactive-streams-2.0.6.jar
com.yahoo.datasketches-memory-0.8.3.jar
com.yahoo.datasketches-sketches-core-0.8.3.jar
io.airlift-aircompressor-0.20.jar
io.dropwizard.metrics-metrics-core-4.1.12.1.jar
io.dropwizard.metrics-metrics-graphite-4.1.12.1.jar
io.dropwizard.metrics-metrics-jmx-4.1.12.1.jar
io.dropwizard.metrics-metrics-jvm-4.1.12.1.jar
io.etcd-jetcd-api-0.7.5.jar
io.etcd-jetcd-common-0.7.5.jar
io.etcd-jetcd-core-0.7.5.jar
io.etcd-jetcd-grpc-0.7.5.jar
io.grpc-grpc-all-1.55.3.jar
io.grpc-grpc-alts-1.55.3.jar
io.grpc-grpc-api-1.55.3.jar
io.grpc-grpc-auth-1.55.3.jar
io.grpc-grpc-context-1.55.3.jar
io.grpc-grpc-core-1.55.3.jar
io.grpc-grpc-grpclb-1.55.3.jar
io.grpc-grpc-netty-1.55.3.jar
io.grpc-grpc-netty-shaded-1.55.3.jar
io.grpc-grpc-protobuf-1.55.3.jar
io.grpc-grpc-protobuf-lite-1.55.3.jar
io.grpc-grpc-rls-1.55.3.jar
io.grpc-grpc-services-1.55.3.jar
io.grpc-grpc-servlet-1.55.3.jar
io.grpc-grpc-servlet-jakarta-1.55.3.jar
io.grpc-grpc-stub-1.55.3.jar
io.grpc-grpc-xds-1.55.3.jar
io.gsonfire-gson-fire-1.8.5.jar
io.jsonwebtoken-jjwt-api-0.11.1.jar
io.jsonwebtoken-jjwt-impl-0.11.1.jar
io.jsonwebtoken-jjwt-jackson-0.11.1.jar
io.kubernetes-client-java-18.0.0.jar
io.kubernetes-client-java-api-18.0.0.jar
io.kubernetes-client-java-proto-18.0.0.jar
io.netty.incubator-netty-incubator-transport-classes-io_uring-0.0.24.Final.jar
io.netty.incubator-netty-incubator-transport-native-io_uring-0.0.24.Final-linux-aarch_64.jar
io.netty.incubator-netty-incubator-transport-native-io_uring-0.0.24.Final-linux-x86_64.jar
io.netty-netty-codec-4.1.105.Final.jar
io.netty-netty-codec-dns-4.1.105.Final.jar
io.netty-netty-codec-haproxy-4.1.105.Final.jar
io.netty-netty-codec-http2-4.1.105.Final.jar
io.netty-netty-codec-http-4.1.105.Final.jar
io.netty-netty-codec-socks-4.1.105.Final.jar
io.netty-netty-common-4.1.105.Final.jar
io.netty-netty-handler-4.1.105.Final.jar
io.netty-netty-handler-proxy-4.1.105.Final.jar
io.netty-netty-resolver-4.1.105.Final.jar
io.netty-netty-resolver-dns-4.1.105.Final.jar
io.netty-netty-resolver-dns-classes-macos-4.1.105.Final.jar
io.netty-netty-resolver-dns-native-macos-4.1.105.Final-osx-aarch_64.jar
io.netty-netty-resolver-dns-native-macos-4.1.105.Final-osx-x86_64.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final-linux-aarch_64.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final-linux-x86_64.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final-osx-aarch_64.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final-osx-x86_64.jar
io.netty-netty-tcnative-boringssl-static-2.0.61.Final-windows-x86_64.jar
io.netty-netty-tcnative-classes-2.0.61.Final.jar
io.netty-netty-transport-4.1.105.Final.jar
io.netty-netty-transport-classes-epoll-4.1.105.Final.jar
io.netty-netty-transport-native-epoll-4.1.105.Final-linux-aarch_64.jar
io.netty-netty-transport-native-epoll-4.1.105.Final-linux-x86_64.jar
io.netty-netty-transport-native-unix-common-4.1.105.Final.jar
io.netty-netty-transport-native-unix-common-4.1.105.Final-linux-x86_64.jar
io.opencensus-opencensus-api-0.28.0.jar
io.opencensus-opencensus-contrib-http-util-0.28.0.jar
io.opencensus-opencensus-proto-0.2.0.jar
io.perfmark-perfmark-api-0.26.0.jar
io.prometheus.jmx-collector-0.16.1.jar
io.prometheus-simpleclient-0.16.0.jar
io.prometheus-simpleclient_caffeine-0.16.0.jar
io.prometheus-simpleclient_common-0.16.0.jar
io.prometheus-simpleclient_hotspot-0.16.0.jar
io.prometheus-simpleclient_httpserver-0.16.0.jar
io.prometheus-simpleclient_jetty-0.16.0.jar
io.prometheus-simpleclient_log4j2-0.16.0.jar
io.prometheus-simpleclient_servlet-0.16.0.jar
io.prometheus-simpleclient_servlet_common-0.16.0.jar
io.prometheus-simpleclient_tracer_common-0.16.0.jar
io.prometheus-simpleclient_tracer_otel-0.16.0.jar
io.prometheus-simpleclient_tracer_otel_agent-0.16.0.jar
io.reactivex.rxjava3-rxjava-3.0.1.jar
io.swagger-swagger-annotations-1.6.2.jar
io.swagger-swagger-core-1.6.2.jar
io.swagger-swagger-models-1.6.2.jar
io.vertx-vertx-auth-common-4.3.8.jar
io.vertx-vertx-bridge-common-4.3.8.jar
io.vertx-vertx-core-4.3.8.jar
io.vertx-vertx-grpc-4.3.5.jar
io.vertx-vertx-web-4.3.8.jar
io.vertx-vertx-web-common-4.3.8.jar
jakarta.activation-jakarta.activation-api-1.2.2.jar
jakarta.annotation-jakarta.annotation-api-1.3.5.jar
jakarta.validation-jakarta.validation-api-2.0.2.jar
jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar
jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar
javax.annotation-javax.annotation-api-1.3.2.jar
javax.servlet-javax.servlet-api-3.1.0.jar
javax.validation-validation-api-1.1.0.Final.jar
javax.websocket-javax.websocket-client-api-1.0.jar
javax.ws.rs-javax.ws.rs-api-2.1.jar
javax.xml.bind-jaxb-api-2.3.1.jar
jline-jline-2.14.6.jar
managed-ledger.jar
net.bytebuddy-byte-buddy-1.14.12.jar
net.java.dev.jna-jna-jpms-5.12.1.jar
net.java.dev.jna-jna-platform-jpms-5.12.1.jar
net.jcip-jcip-annotations-1.0.jar
net.jodah-failsafe-2.4.4.jar
net.jodah-typetools-0.5.0.jar
netty-buffer-4.1.111.Final-SNAPSHOT.jar
org.apache.avro-avro-1.11.3.jar
org.apache.avro-avro-protobuf-1.11.3.jar
org.apache.bookkeeper-bookkeeper-benchmark-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-common-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-common-allocator-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-perf-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-proto-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-server-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-slogger-api-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-slogger-slf4j-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-tools-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-tools-framework-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-bookkeeper-tools-ledger-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-circe-checksum-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-cpu-affinity-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.http-http-server-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.http-vertx-http-server-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-native-io-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-statelib-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.stats-bookkeeper-stats-api-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.stats-codahale-metrics-provider-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.stats-prometheus-metrics-provider-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-stream-storage-cli-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-stream-storage-java-client-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-stream-storage-server-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-stream-storage-service-api-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper-stream-storage-service-impl-4.16.6-SNAPSHOT.jar
org.apache.bookkeeper.tests-stream-storage-tests-common-4.16.6-SNAPSHOT.jar
org.apache.commons-commons-collections4-4.4.jar
org.apache.commons-commons-compress-1.26.0.jar
org.apache.commons-commons-lang3-3.11.jar
org.apache.commons-commons-text-1.10.0.jar
org.apache.curator-curator-client-5.1.0.jar
org.apache.curator-curator-framework-5.1.0.jar
org.apache.curator-curator-recipes-5.1.0.jar
org.apache.distributedlog-distributedlog-common-4.16.4.jar
org.apache.distributedlog-distributedlog-core-4.16.4.jar
org.apache.distributedlog-distributedlog-core-4.16.4-tests.jar
org.apache.distributedlog-distributedlog-protocol-4.16.4.jar
org.apache.httpcomponents-httpclient-4.5.13.jar
org.apache.httpcomponents-httpcore-4.4.15.jar
org.apache.logging.log4j-log4j-api-2.18.0.jar
org.apache.logging.log4j-log4j-core-2.18.0.jar
org.apache.logging.log4j-log4j-slf4j-impl-2.18.0.jar
org.apache.logging.log4j-log4j-web-2.18.0.jar
org.apache.pulsar-bouncy-castle-bc-3.2.2-pkg.jar
org.apache.pulsar-pulsar-broker-3.2.2.jar
org.apache.pulsar-pulsar-broker-auth-oidc-3.2.2.jar
org.apache.pulsar-pulsar-broker-auth-sasl-3.2.2.jar
org.apache.pulsar-pulsar-broker-common-3.2.2.jar
org.apache.pulsar-pulsar-client-admin-api-3.2.2.jar
org.apache.pulsar-pulsar-client-admin-original-3.2.2.jar
org.apache.pulsar-pulsar-client-api-3.2.2.jar
org.apache.pulsar-pulsar-client-auth-sasl-3.2.2.jar
org.apache.pulsar-pulsar-client-messagecrypto-bc-3.2.2.jar
org.apache.pulsar-pulsar-client-original-3.2.2.jar
org.apache.pulsar-pulsar-client-tools-3.2.2.jar
org.apache.pulsar-pulsar-client-tools-api-3.2.2.jar
org.apache.pulsar-pulsar-cli-utils-3.2.2.jar
org.apache.pulsar-pulsar-common-3.2.2.jar
org.apache.pulsar-pulsar-config-validation-3.2.2.jar
org.apache.pulsar-pulsar-docs-tools-3.2.2.jar
org.apache.pulsar-pulsar-functions-api-3.2.2.jar
org.apache.pulsar-pulsar-functions-instance-3.2.2.jar
org.apache.pulsar-pulsar-functions-local-runner-original-3.2.2.jar
org.apache.pulsar-pulsar-functions-proto-3.2.2.jar
org.apache.pulsar-pulsar-functions-runtime-3.2.2.jar
org.apache.pulsar-pulsar-functions-secrets-3.2.2.jar
org.apache.pulsar-pulsar-functions-utils-3.2.2.jar
org.apache.pulsar-pulsar-functions-worker-3.2.2.jar
org.apache.pulsar-pulsar-io-core-3.2.2.jar
org.apache.pulsar-pulsar-metadata-3.2.2.jar
org.apache.pulsar-pulsar-package-bookkeeper-storage-3.2.2.jar
org.apache.pulsar-pulsar-package-core-3.2.2.jar
org.apache.pulsar-pulsar-package-filesystem-storage-3.2.2.jar
org.apache.pulsar-pulsar-proxy-3.2.2.jar
org.apache.pulsar-pulsar-transaction-common-3.2.2.jar
org.apache.pulsar-pulsar-transaction-coordinator-3.2.2.jar
org.apache.pulsar-pulsar-websocket-3.2.2.jar
org.apache.pulsar-testmocks-3.2.2.jar
org.apache.thrift-libthrift-0.14.2.jar
org.apache.yetus-audience-annotations-0.12.0.jar
org.apache.zookeeper-zookeeper-3.9.2.jar
org.apache.zookeeper-zookeeper-jute-3.9.2.jar
org.apache.zookeeper-zookeeper-prometheus-metrics-3.9.2.jar
org.asynchttpclient-async-http-client-2.12.1.jar
org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar
org.bitbucket.b_c-jose4j-0.9.4.jar
org.bouncycastle-bcpkix-jdk18on-1.75.jar
org.bouncycastle-bcprov-ext-jdk18on-1.75.jar
org.bouncycastle-bcprov-jdk18on-1.75.jar
org.bouncycastle-bcutil-jdk18on-1.75.jar
org.checkerframework-checker-qual-3.33.0.jar
org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar
org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-alpn-server-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-client-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-continuation-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-http-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-io-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-proxy-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-security-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-server-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-servlet-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-servlets-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-util-9.4.54.v20240208.jar
org.eclipse.jetty-jetty-util-ajax-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-websocket-api-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-websocket-client-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-websocket-common-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-websocket-server-9.4.54.v20240208.jar
org.eclipse.jetty.websocket-websocket-servlet-9.4.54.v20240208.jar
org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar
org.glassfish.hk2.external-jakarta.inject-2.6.1.jar
org.glassfish.hk2-hk2-api-2.6.1.jar
org.glassfish.hk2-hk2-locator-2.6.1.jar
org.glassfish.hk2-hk2-utils-2.6.1.jar
org.glassfish.hk2-osgi-resource-locator-1.0.3.jar
org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar
org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar
org.glassfish.jersey.core-jersey-client-2.34.jar
org.glassfish.jersey.core-jersey-common-2.34.jar
org.glassfish.jersey.core-jersey-server-2.34.jar
org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar
org.glassfish.jersey.inject-jersey-hk2-2.34.jar
org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar
org.glassfish.jersey.media-jersey-media-multipart-2.34.jar
org.hdrhistogram-HdrHistogram-2.1.9.jar
org.javassist-javassist-3.25.0-GA.jar
org.jctools-jctools-core-2.1.2.jar
org.jetbrains-annotations-13.0.jar
org.jetbrains.kotlin-kotlin-stdlib-1.8.20.jar
org.jetbrains.kotlin-kotlin-stdlib-common-1.8.20.jar
org.jetbrains.kotlin-kotlin-stdlib-jdk7-1.8.20.jar
org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.8.20.jar
org.jline-jline-3.21.0.jar
org.jvnet.mimepull-mimepull-1.9.13.jar
org.reactivestreams-reactive-streams-1.0.3.jar
org.roaringbitmap-RoaringBitmap-0.9.44.jar
org.rocksdb-rocksdbjni-7.9.2.jar
org.slf4j-jcl-over-slf4j-1.7.32.jar
org.slf4j-slf4j-api-1.7.32.jar
org.xerial.snappy-snappy-java-1.1.10.5.jar
org.yaml-snakeyaml-2.0.jar
org.zeroturnaround-zt-zip-1.17.jar
protobuf-java-3.25.1.jar
pulsar-testclient.jar

Start standalone pulsar

# Use older Bookkeeper wire protocol with bookie
bookkeeperUseV2WireProtocol=true
 
bin/pulsar-daemon stop broker
bin/pulsar-daemon stop bookie
bin/pulsar-daemon stop zookeeper
 
rm logs/*
bin/pulsar-daemon start zookeeper
bin/pulsar-daemon start bookie
bin/bookkeeper shell bookiesanity
bin/pulsar-daemon start broker
 
tail -f logs/pulsar-broker-cockroach308.log
 

Test

bin/pulsar-perf consume persistent://public/default/my-topic-6 -n 10 -sp Latest -ss angus_test -st Key_Shared
bin/pulsar-perf produce persistent://public/default/my-topic-6 -r 6000 -s 2000 -bp 2 -db -b 1

Result

No error after few minutes


 tail -f logs/pulsar-broker-cockroach308.log 
2024-05-29T08:26:16,146+0000 [BookKeeperClientWorker-OrderedExecutor-15-0] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Starting TLS handshake with 100.96.184.253:3181
2024-05-29T08:26:16,147+0000 [pulsar-io-3-9] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,148+0000 [pulsar-io-3-11] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,149+0000 [pulsar-io-3-12] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,149+0000 [pulsar-io-3-4] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,149+0000 [pulsar-io-3-5] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,150+0000 [pulsar-io-3-14] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,150+0000 [pulsar-io-3-15] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,151+0000 [pulsar-io-3-13] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie using TLS: 100.96.184.253:3181
2024-05-29T08:26:16,151+0000 [pulsar-io-3-19] INFO  org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to boo