Skip to content

Commit 22ff023

Browse files
StevenLuMTBewareMyPower
authored andcommitted
[improve][broker] Upgrade bookkeeper to 4.17.2/commons-configuration to 2.x/grpc to 1.72.0 and enable ZooKeeper client to establish connection in read-only mode (#24468)
(cherry picked from commit 8d1ec6d)
1 parent 2107ff0 commit 22ff023

File tree

12 files changed

+76
-66
lines changed

12 files changed

+76
-66
lines changed

distribution/server/src/assemble/LICENSE.bin.txt

Lines changed: 56 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ The Apache Software License, Version 2.0
263263
* Caffeine -- com.github.ben-manes.caffeine-caffeine-2.9.1.jar
264264
* Conscrypt -- org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar
265265
* Fastutil -- it.unimi.dsi-fastutil-8.5.14.jar
266-
* Proto Google Common Protos -- com.google.api.grpc-proto-google-common-protos-2.17.0.jar
266+
* Proto Google Common Protos -- com.google.api.grpc-proto-google-common-protos-2.51.0.jar
267267
* Bitbucket -- org.bitbucket.b_c-jose4j-0.9.4.jar
268268
* Gson
269269
- com.google.code.gson-gson-2.8.9.jar
@@ -282,14 +282,17 @@ The Apache Software License, Version 2.0
282282
- com.yahoo.datasketches-memory-0.8.3.jar
283283
- com.yahoo.datasketches-sketches-core-0.8.3.jar
284284
* Apache Commons
285+
- commons-beanutils-commons-beanutils-1.11.0.jar
285286
- commons-cli-commons-cli-1.9.0.jar
286287
- commons-codec-commons-codec-1.18.0.jar
287288
- commons-configuration-commons-configuration-1.10.jar
288289
- commons-io-commons-io-2.19.0.jar
289290
- commons-lang-commons-lang-2.6.jar
290291
- commons-logging-commons-logging-1.1.1.jar
292+
- commons-collections-commons-collections-3.2.2.jar
291293
- org.apache.commons-commons-collections4-4.4.jar
292294
- org.apache.commons-commons-compress-1.27.1.jar
295+
- org.apache.commons-commons-configuration2-2.12.0.jar
293296
- org.apache.commons-commons-lang3-3.17.0.jar
294297
- org.apache.commons-commons-text-1.13.1.jar
295298
* Netty
@@ -356,34 +359,34 @@ The Apache Software License, Version 2.0
356359
- net.java.dev.jna-jna-jpms-5.12.1.jar
357360
- net.java.dev.jna-jna-platform-jpms-5.12.1.jar
358361
* BookKeeper
359-
- org.apache.bookkeeper-bookkeeper-common-4.17.1.jar
360-
- org.apache.bookkeeper-bookkeeper-common-allocator-4.17.1.jar
361-
- org.apache.bookkeeper-bookkeeper-proto-4.17.1.jar
362-
- org.apache.bookkeeper-bookkeeper-server-4.17.1.jar
363-
- org.apache.bookkeeper-bookkeeper-tools-framework-4.17.1.jar
364-
- org.apache.bookkeeper-circe-checksum-4.17.1.jar
365-
- org.apache.bookkeeper-cpu-affinity-4.17.1.jar
366-
- org.apache.bookkeeper-statelib-4.17.1.jar
367-
- org.apache.bookkeeper-stream-storage-api-4.17.1.jar
368-
- org.apache.bookkeeper-stream-storage-common-4.17.1.jar
369-
- org.apache.bookkeeper-stream-storage-java-client-4.17.1.jar
370-
- org.apache.bookkeeper-stream-storage-java-client-base-4.17.1.jar
371-
- org.apache.bookkeeper-stream-storage-proto-4.17.1.jar
372-
- org.apache.bookkeeper-stream-storage-server-4.17.1.jar
373-
- org.apache.bookkeeper-stream-storage-service-api-4.17.1.jar
374-
- org.apache.bookkeeper-stream-storage-service-impl-4.17.1.jar
375-
- org.apache.bookkeeper.http-http-server-4.17.1.jar
376-
- org.apache.bookkeeper.http-vertx-http-server-4.17.1.jar
377-
- org.apache.bookkeeper.stats-bookkeeper-stats-api-4.17.1.jar
378-
- org.apache.bookkeeper.stats-prometheus-metrics-provider-4.17.1.jar
379-
- org.apache.distributedlog-distributedlog-common-4.17.1.jar
380-
- org.apache.distributedlog-distributedlog-core-4.17.1-tests.jar
381-
- org.apache.distributedlog-distributedlog-core-4.17.1.jar
382-
- org.apache.distributedlog-distributedlog-protocol-4.17.1.jar
383-
- org.apache.bookkeeper.stats-codahale-metrics-provider-4.17.1.jar
384-
- org.apache.bookkeeper-bookkeeper-slogger-api-4.17.1.jar
385-
- org.apache.bookkeeper-bookkeeper-slogger-slf4j-4.17.1.jar
386-
- org.apache.bookkeeper-native-io-4.17.1.jar
362+
- org.apache.bookkeeper-bookkeeper-common-4.17.2.jar
363+
- org.apache.bookkeeper-bookkeeper-common-allocator-4.17.2.jar
364+
- org.apache.bookkeeper-bookkeeper-proto-4.17.2.jar
365+
- org.apache.bookkeeper-bookkeeper-server-4.17.2.jar
366+
- org.apache.bookkeeper-bookkeeper-tools-framework-4.17.2.jar
367+
- org.apache.bookkeeper-circe-checksum-4.17.2.jar
368+
- org.apache.bookkeeper-cpu-affinity-4.17.2.jar
369+
- org.apache.bookkeeper-statelib-4.17.2.jar
370+
- org.apache.bookkeeper-stream-storage-api-4.17.2.jar
371+
- org.apache.bookkeeper-stream-storage-common-4.17.2.jar
372+
- org.apache.bookkeeper-stream-storage-java-client-4.17.2.jar
373+
- org.apache.bookkeeper-stream-storage-java-client-base-4.17.2.jar
374+
- org.apache.bookkeeper-stream-storage-proto-4.17.2.jar
375+
- org.apache.bookkeeper-stream-storage-server-4.17.2.jar
376+
- org.apache.bookkeeper-stream-storage-service-api-4.17.2.jar
377+
- org.apache.bookkeeper-stream-storage-service-impl-4.17.2.jar
378+
- org.apache.bookkeeper.http-http-server-4.17.2.jar
379+
- org.apache.bookkeeper.http-vertx-http-server-4.17.2.jar
380+
- org.apache.bookkeeper.stats-bookkeeper-stats-api-4.17.2.jar
381+
- org.apache.bookkeeper.stats-prometheus-metrics-provider-4.17.2.jar
382+
- org.apache.distributedlog-distributedlog-common-4.17.2.jar
383+
- org.apache.distributedlog-distributedlog-core-4.17.2-tests.jar
384+
- org.apache.distributedlog-distributedlog-core-4.17.2.jar
385+
- org.apache.distributedlog-distributedlog-protocol-4.17.2.jar
386+
- org.apache.bookkeeper.stats-codahale-metrics-provider-4.17.2.jar
387+
- org.apache.bookkeeper-bookkeeper-slogger-api-4.17.2.jar
388+
- org.apache.bookkeeper-bookkeeper-slogger-slf4j-4.17.2.jar
389+
- org.apache.bookkeeper-native-io-4.17.2.jar
387390
* Apache HTTP Client
388391
- org.apache.httpcomponents-httpclient-4.5.13.jar
389392
- org.apache.httpcomponents-httpcore-4.4.15.jar
@@ -430,29 +433,31 @@ The Apache Software License, Version 2.0
430433
- org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.8.20.jar
431434
- org.jetbrains-annotations-13.0.jar
432435
* gRPC
433-
- io.grpc-grpc-all-1.56.1.jar
434-
- io.grpc-grpc-auth-1.56.1.jar
435-
- io.grpc-grpc-context-1.56.1.jar
436-
- io.grpc-grpc-core-1.56.1.jar
437-
- io.grpc-grpc-protobuf-1.56.1.jar
438-
- io.grpc-grpc-protobuf-lite-1.56.1.jar
439-
- io.grpc-grpc-stub-1.56.1.jar
440-
- io.grpc-grpc-alts-1.56.1.jar
441-
- io.grpc-grpc-api-1.56.1.jar
442-
- io.grpc-grpc-grpclb-1.56.1.jar
443-
- io.grpc-grpc-netty-shaded-1.56.1.jar
444-
- io.grpc-grpc-services-1.56.1.jar
445-
- io.grpc-grpc-xds-1.56.1.jar
446-
- io.grpc-grpc-rls-1.56.1.jar
447-
- io.grpc-grpc-servlet-1.56.1.jar
448-
- io.grpc-grpc-servlet-jakarta-1.56.1.jar
436+
- io.grpc-grpc-all-1.72.0.jar
437+
- io.grpc-grpc-auth-1.72.0.jar
438+
- io.grpc-grpc-context-1.72.0.jar
439+
- io.grpc-grpc-core-1.72.0.jar
440+
- io.grpc-grpc-protobuf-1.72.0.jar
441+
- io.grpc-grpc-protobuf-lite-1.72.0.jar
442+
- io.grpc-grpc-stub-1.72.0.jar
443+
- io.grpc-grpc-alts-1.72.0.jar
444+
- io.grpc-grpc-api-1.72.0.jar
445+
- io.grpc-grpc-grpclb-1.72.0.jar
446+
- io.grpc-grpc-netty-shaded-1.72.0.jar
447+
- io.grpc-grpc-services-1.72.0.jar
448+
- io.grpc-grpc-xds-1.72.0.jar
449+
- io.grpc-grpc-rls-1.72.0.jar
450+
- io.grpc-grpc-servlet-1.72.0.jar
451+
- io.grpc-grpc-servlet-jakarta-1.72.0.jar
449452
- io.grpc-grpc-util-1.60.0.jar
453+
- io.grpc-grpc-opentelemetry-1.72.0.jar
454+
- io.grpc-grpc-gcp-csm-observability-1.72.0.jar
455+
- io.grpc-grpc-inprocess-1.72.0.jar
450456
* Perfmark
451457
- io.perfmark-perfmark-api-0.26.0.jar
452458
* OpenCensus
453459
- io.opencensus-opencensus-api-0.28.0.jar
454460
- io.opencensus-opencensus-contrib-http-util-0.28.0.jar
455-
- io.opencensus-opencensus-proto-0.2.0.jar
456461
* Jodah
457462
- net.jodah-typetools-0.5.0.jar
458463
- dev.failsafe-failsafe-3.3.2.jar
@@ -506,7 +511,7 @@ The Apache Software License, Version 2.0
506511
* Google HTTP Client
507512
- com.google.http-client-google-http-client-gson-1.41.0.jar
508513
- com.google.http-client-google-http-client-1.41.0.jar
509-
- com.google.auto.value-auto-value-annotations-1.10.1.jar
514+
- com.google.auto.value-auto-value-annotations-1.11.0.jar
510515
- com.google.re2j-re2j-1.7.jar
511516
* Jetcd - shaded
512517
* IPAddress
@@ -537,15 +542,17 @@ The Apache Software License, Version 2.0
537542
- io.opentelemetry.instrumentation-opentelemetry-runtime-telemetry-java17-1.33.6-alpha.jar
538543
- io.opentelemetry.instrumentation-opentelemetry-runtime-telemetry-java8-1.33.6-alpha.jar
539544
- io.opentelemetry.semconv-opentelemetry-semconv-1.29.0-alpha.jar
545+
- com.google.cloud.opentelemetry-detector-resources-support-0.33.0.jar
546+
- io.opentelemetry.contrib-opentelemetry-gcp-resources-1.43.0-alpha.jar
540547
* Spotify completable-futures
541548
- com.spotify-completable-futures-0.3.6.jar
542549
* JSpecify
543550
- org.jspecify-jspecify-1.0.0.jar
544551

545552
BSD 3-clause "New" or "Revised" License
546553
* Google auth library
547-
- com.google.auth-google-auth-library-credentials-1.4.0.jar -- ../licenses/LICENSE-google-auth-library.txt
548-
- com.google.auth-google-auth-library-oauth2-http-1.4.0.jar -- ../licenses/LICENSE-google-auth-library.txt
554+
- com.google.auth-google-auth-library-credentials-1.24.1.jar -- ../licenses/LICENSE-google-auth-library.txt
555+
- com.google.auth-google-auth-library-oauth2-http-1.24.1.jar -- ../licenses/LICENSE-google-auth-library.txt
549556
* LevelDB -- (included in org.rocksdb.*.jar) -- ../licenses/LICENSE-LevelDB.txt
550557
* JSR305 -- com.google.code.findbugs-jsr305-3.0.2.jar -- ../licenses/LICENSE-JSR305.txt
551558
* JLine -- jline-jline-2.14.6.jar -- ../licenses/LICENSE-JLine.txt

distribution/shell/src/assemble/LICENSE.bin.txt

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -341,13 +341,14 @@ The Apache Software License, Version 2.0
341341
- sketches-core-0.8.3.jar
342342
* Apache Commons
343343
- commons-codec-1.18.0.jar
344-
- commons-configuration-1.10.jar
345344
- commons-io-2.19.0.jar
346-
- commons-lang-2.6.jar
347345
- commons-logging-1.2.jar
348346
- commons-lang3-3.17.0.jar
349347
- commons-text-1.13.1.jar
350348
- commons-compress-1.27.1.jar
349+
- commons-beanutils-1.11.0.jar
350+
- commons-collections-3.2.2.jar
351+
- commons-configuration2-2.12.0.jar
351352
* Netty
352353
- netty-buffer-4.1.122.Final.jar
353354
- netty-codec-4.1.122.Final.jar
@@ -395,9 +396,9 @@ The Apache Software License, Version 2.0
395396
- opentelemetry-context-1.45.0.jar
396397

397398
* BookKeeper
398-
- bookkeeper-common-allocator-4.17.1.jar
399-
- cpu-affinity-4.17.1.jar
400-
- circe-checksum-4.17.1.jar
399+
- bookkeeper-common-allocator-4.17.2.jar
400+
- cpu-affinity-4.17.2.jar
401+
- circe-checksum-4.17.2.jar
401402
* AirCompressor
402403
- aircompressor-0.27.jar
403404
* AsyncHttpClient

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,7 @@ flexible messaging model and an intuitive client API.</description>
177177
<!-- apache commons -->
178178
<commons-compress.version>1.27.1</commons-compress.version>
179179

180-
<bookkeeper.version>4.17.1</bookkeeper.version>
180+
<bookkeeper.version>4.17.2</bookkeeper.version>
181181
<zookeeper.version>3.9.3</zookeeper.version>
182182
<commons-cli.version>1.9.0</commons-cli.version>
183183
<commons-text.version>1.13.1</commons-text.version>
@@ -212,7 +212,7 @@ flexible messaging model and an intuitive client API.</description>
212212
<zt-zip.version>1.17</zt-zip.version>
213213
<protobuf3.version>3.25.5</protobuf3.version>
214214
<protoc3.version>${protobuf3.version}</protoc3.version>
215-
<grpc.version>1.56.1</grpc.version>
215+
<grpc.version>1.72.0</grpc.version>
216216
<google-http-client.version>1.41.0</google-http-client.version>
217217
<perfmark.version>0.26.0</perfmark.version>
218218
<protoc-gen-grpc-java.version>${grpc.version}</protoc-gen-grpc-java.version>

pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
import org.apache.bookkeeper.net.BookieNode;
4141
import org.apache.bookkeeper.net.BookieSocketAddress;
4242
import org.apache.bookkeeper.proto.BookieAddressResolver;
43-
import org.apache.commons.configuration.Configuration;
43+
import org.apache.commons.configuration2.Configuration;
4444
import org.apache.commons.lang3.StringUtils;
4545
import org.apache.pulsar.common.policies.data.BookieInfo;
4646
import org.apache.pulsar.common.policies.data.BookiesRackConfiguration;

pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
import org.apache.bookkeeper.replication.AutoRecoveryMain;
4444
import org.apache.bookkeeper.server.conf.BookieConfiguration;
4545
import org.apache.bookkeeper.stats.StatsProvider;
46-
import org.apache.commons.configuration.ConfigurationException;
46+
import org.apache.commons.configuration2.ex.ConfigurationException;
4747
import org.apache.logging.log4j.LogManager;
4848
import org.apache.logging.log4j.core.util.datetime.FixedDateFormat;
4949
import org.apache.pulsar.broker.PulsarServerException;

pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import org.apache.bookkeeper.stream.storage.api.cluster.ClusterInitializer;
3030
import org.apache.bookkeeper.stream.storage.impl.cluster.ZkClusterInitializer;
3131
import org.apache.bookkeeper.util.BookKeeperConstants;
32+
import org.apache.commons.configuration2.convert.DisabledListDelimiterHandler;
3233
import org.apache.pulsar.bookie.rackawareness.BookieRackAffinityMapping;
3334
import org.apache.pulsar.broker.resources.NamespaceResources;
3435
import org.apache.pulsar.broker.resources.PulsarResources;
@@ -304,7 +305,7 @@ private static void initializeCluster(Arguments arguments, int bundleNumberForDe
304305
// Format BookKeeper ledger storage metadata
305306
if (arguments.existingBkMetadataServiceUri == null && arguments.bookieMetadataServiceUri == null) {
306307
ServerConfiguration bkConf = new ServerConfiguration();
307-
bkConf.setDelimiterParsingDisabled(true);
308+
bkConf.setListDelimiterHandler(new DisabledListDelimiterHandler());
308309
bkConf.setMetadataServiceUri("metadata-store:" + arguments.metadataStoreUrl);
309310
bkConf.setZkTimeout(arguments.zkSessionTimeoutMillis);
310311
// only format if /ledgers doesn't exist

pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
import org.apache.bookkeeper.stats.NullStatsProvider;
4040
import org.apache.bookkeeper.stats.StatsLogger;
4141
import org.apache.bookkeeper.stats.StatsProvider;
42-
import org.apache.commons.configuration.Configuration;
42+
import org.apache.commons.configuration2.Configuration;
4343
import org.apache.pulsar.broker.stats.prometheus.metrics.PrometheusMetricsProvider;
4444
import org.apache.pulsar.broker.storage.BookkeeperManagedLedgerStorageClass;
4545
import org.apache.pulsar.broker.storage.ManagedLedgerStorage;

pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/PrometheusMetricsProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
import org.apache.bookkeeper.stats.CachingStatsProvider;
3232
import org.apache.bookkeeper.stats.StatsLogger;
3333
import org.apache.bookkeeper.stats.StatsProvider;
34-
import org.apache.commons.configuration.Configuration;
34+
import org.apache.commons.configuration2.Configuration;
3535
import org.apache.commons.lang3.StringUtils;
3636
import org.apache.pulsar.client.util.ExecutorProvider;
3737

pulsar-broker/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@
6767
import org.apache.bookkeeper.stream.server.StreamStorageLifecycleComponent;
6868
import org.apache.bookkeeper.stream.storage.api.cluster.ClusterInitializer;
6969
import org.apache.bookkeeper.stream.storage.impl.cluster.ZkClusterInitializer;
70-
import org.apache.commons.configuration.CompositeConfiguration;
70+
import org.apache.commons.configuration2.CompositeConfiguration;
7171
import org.apache.commons.io.FileUtils;
7272
import org.apache.zookeeper.CreateMode;
7373
import org.apache.zookeeper.KeeperException;

pulsar-broker/src/test/java/org/apache/pulsar/broker/BookKeeperClientFactoryImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
import org.apache.bookkeeper.conf.ClientConfiguration;
3737
import org.apache.bookkeeper.net.CachedDNSToSwitchMapping;
3838
import org.apache.bookkeeper.stats.StatsLogger;
39-
import org.apache.commons.configuration.ConfigurationException;
39+
import org.apache.commons.configuration2.ex.ConfigurationException;
4040
import org.apache.commons.lang3.reflect.FieldUtils;
4141
import org.apache.pulsar.bookie.rackawareness.BookieRackAffinityMapping;
4242
import org.apache.pulsar.metadata.api.MetadataStore;

0 commit comments

Comments
 (0)