This is an automated email from the ASF dual-hosted git repository.
xiangying pushed a change to branch pip/minCompressSize
in repository https://gitbox.apache.org/repos/asf/pulsar.git
omit f56999ae480 add test
omit 90965ce4b01 Merge remote-tracking branch 'apache/master' into
pip/minCompressSize
omit 6bf52a3adba [improve][client] Add a producer config to improve
compaction performance
omit 7b80f019fa8 [fix] [broker] Fix race-condition causing repeated delete
topic (#23522)
omit 266e705d29e [improve][broker] re-elect the channel owner if no channel
owner is found (#23516)
omit ebb3cb5384d [fix][standalone] correctly delete bookie registration
znode (#23497)
omit fcb359299e9 [fix][client] Fix Reader.hasMessageAvailable return wrong
value after seeking by timestamp with startMessageIdInclusive (#23502)
omit ff4a25e8f78 [fix][client] Fix producer/consumer stop to reconnect or
Pub/Sub due to IO thread race-condition (#23499)
omit 1344167328c [fix][broker] Key_Shared subscription: Reject consumers
with incompatible policy (#23449)
omit 06471dd3054 [fix][test] Fix running ClusterMetadataSetupTest in IDE
(#23492)
omit a0beab02954 [fix] [proxy] Fix pattern consumer does not work when
using Proxy (#23489)
omit 7367f1c6553 [fix][test] Prevent OOM in test by not spying invocations
in SimpleProducerConsumerTest (#23486)
omit 9db5f010222 [improve][io] Upgrade Spring version to 6.1.14 in IO
Connectors (#23481)
omit 2ef8ef0a711 [improve][monitor] Upgrade OTel to 1.41.0 (#23484)
omit 2d88a4e8b9f [fix][test] Fix memory leak via OTel shutdown hooks in
tests (#23483)
omit 8de27a21165 [improve][test] Added message properties tests for batch
and non-batch messages (#23473)
omit 6ebca5e4a4b [feat][monitor] Add offloader stats grafana dashboard
(#23479)
omit 63c6a25718f [fix][client] Prevent embedding protobuf-java class files
in pulsar-client-admin and pulsar-client-all (#23468)
omit 6933a1d59b7 [fix][ci] Temporarily move OneWayReplicatorTestBase tests
to flaky group to unblock CI (#23478)
omit 93384dd4c3e [feat][meta] Bump oxia java version from 0.4.5 to 0.4.7
(#23471)
omit 842f0ceb262 [fix][client] Fix ConsumerStats.getRateMsgsReceived
javadoc (#21618)
omit 9d2606d73b9 [improve][build] Upgrade os-maven-plugin to support RISC-V
64 (#23465)
omit 81385c5f971 [improve][ci] Prevent git force push to more recent
maintenance branches (#23464)
omit f98297f3c9c [fix][client] Use dedicated executor for requests in
BinaryProtoLookupService (#23378)
omit 5a8341afbfb [improve][io] Upgrade Spring version to 6.1.13 in IO
Connectors (#23459)
omit d759a1e6166 [fix][build] Set project version to 4.1.0-SNAPSHOT (#23442)
omit 33475ec456a [improve][broker] Add log to track issue when
`handleGetTopicsOfNamespace` (#23434)
omit 9f7b4877b03 [improve][pip] PIP-367: Propose a Contributor Repository
for Pulsar (#23061)
omit 0c4108b8208 [fix][test] Address flaky
GetPartitionMetadataMultiBrokerTest (#23456)
omit e2fb0daac84 [fix][client] Fix the javadoc for
ConsumerBuilder.isAckReceiptEnabled (#23452)
omit 209fd784765 [fix][build] Add basic support for vscode-java and Eclipse
IDE (#23448)
omit b340a17b8ff [improve][broker][PIP-379] Improve hash collision handling
by restoring consumer when other leaves (#23447)
omit d9bc7af60b2 [fix] [broker] Topics failed to delete after remove
cluster from replicated clusters set and caused OOM (#23360)
omit 4eb1a2938d2 [improve][build] Drop deprecated pulsar-client-1x and
pulsar-client-2x-shaded modules (#23450)
omit fa9b5211a20 [improve][cli] Add compactor type option for compaction
tool (#23446)
omit aa6bc0929bf [fix][test] Fix flaky test
ManagedLedgerTest.testDeleteCurrentLedgerWhenItIsClosed (#23437)
omit 390d7d92734 [improve][broker][PIP-379] Don't replace a consumer when
there's a collision (#23441)
omit 807d1899b79 [fix][build] Remove duplicate dependencies in pom.xml
(#23440)
omit d5e36754394 [fix][sec] Drop hdfs2 support, Upgrade hadoop3 to 3.4.0
and dnsjava to 3.6.2 to address CVE-2024-25638 (#23411)
omit 50dc521f7f9 [fix][broker] normalize path (#23438)
omit 2dace760b03 [improve][client] Add log when can't add message to the
container (#21924)
omit bc3e7f60574 [fix][broker] Allow broker to handle non-recoverable
schema error only if SchemaLedgerForceRecovery flag is enabled (#23428)
omit 5506f50fa03 [fix][broker] Fix namespace unload might be blocked too
long with extensible load manager (#23433)
omit 8b6b3370f92 [fix][broker] Avoid orphan ledgers in
BucketDelayedDeliveryTracker (#22802)
omit 667904c6a66 [Enhancement]Added a metric for geo replication for
tracking replicated subscriptions snapshot timeouts (#22381)
omit b334c4f637b [improve][broker] PIP-383: Support granting/revoking
permissions for multiple topics (#23372)
omit 86003161136 [improve][client] Increase default Java client
connectionMaxIdleSeconds to 60 seconds (#23430)
omit 9f8b4a6d158 [fix][broker] Fix ack hole in cursor for geo-replication
(#20931)
omit acac72ea03f [improve][broker][PIP-379] Add observability stats for
"draining hashes" (#23429)
omit 3dc0adec208 [fix][ci] Pin aquasecurity/[email protected] since
master is broken (#23431)
omit b051dcd71d1 [fix] Reapply shell script parameter passthrough fix
#22867 reverted in #22921 (#22923)
omit c891eaa38a0 [fix][test] Fix flaky
GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic
(#23259)
omit ed01b0e1464 [fix][ml][PIP-327] fix recover from ledger when
ledgerForceRecovery is true (#23426)
omit 1d83a534cf1 [fix][doc] Fix some typos in pip (#23288)
omit 676fdb1ffb4 [improve][broker] PIP-379: Enable the use of the classic
implementation of Key_Shared / Shared with feature flag (#23424)
omit 5aadec02a3e [fix][broker] Fix typos in pulsar-broker and
tiered-storage. (#23415)
omit 84b834f95c8 [improve][broker] PIP-379: Snapshot hash range assignments
only in AUTO_SPLIT ordered mode (#23423)
omit 9579c4dea91 [improve][ci] Upgrade/Downgrade test (#22988)
omit 4d6dee456ca [fix][ml] Remove unnecessary return in ManagedLedgerImpl
(#23418)
omit 3d0625ba642 [improve][broker] PIP-379: Key_Shared Draining Hashes for
Improved Message Ordering (#23352)
omit 4efcc1502f5 [improve][ci] Move some flaky ExtensibleLoadManager tests
to flaky group until they are fixed (#23414)
omit c598974346a [improve][PIP] PIP-383: Support granting/revoking
permissions for multiple topics (#23355)
omit 06fc259ce56 [improve][build] Update maven-wrapper (mvnw) to recent
stable version 3.3.2 (#23410)
omit 731ec8364f0 [improve][broker][PIP-384] Decouple Bookkeeper client from
ManagedLedgerStorage and enable multiple ManagedLedgerFactory instances (#23313)
omit 5451921cd49 [improve] PIP-384: ManagedLedger interface decoupling
(#23363)
omit 806fdf86866 [improve][misc] Upgrade Jetty to 9.4.56.v20240826 (#23405)
omit 6c7ec4c38c8 [feat] [broker] Add broker health check status into
prometheus metrics (#20147)
omit b9ededc30e8 [fix][broker] Fix delivery-test with unnecessary
invocation-count (#23399)
omit 6bca70b1380 [fix][client] Add more info while throwing reader creation
exception (#23401)
omit 64e9687bb55 [improve][pip] PIP-379: Key_Shared Draining Hashes for
Improved Message Ordering (#23309)
omit aa125616aeb [fix][broker] Fix Broker was failing to create producer
with broken schema ledger (#23395)
omit 56200aabc56 [improve][ci] Continue Pulsar CI build even when Trivy
scanner fails (#23397)
omit 1e936778691 [improve][pip] PIP-360 Add admin API to display Schema
metadata (#22938)
omit 38322a689b2 [improve][broker] PIP-327: Support force topic loading for
unrecoverable errors (#21759)
omit fad67613a4b [fix][sec] Upgrade Avro to 1.11.4 to address
CVE-2024-47561 (#23394)
omit c2128dc4a12 [fix] Bump commons-io:commons-io from 2.8.0 to 2.14.0
(#23393)
omit eee9283666c [fix][broker] timeout when broker registry hangs and
monitor broker registry (ExtensibleLoadManagerImpl only) (#23382)
omit ab684a0fb9d [fix][sec] Upgrade protobuf-java to 3.25.5 (#23356)
omit e49d9ad01c9 [improve][pip] PIP-360 Add admin API to display Schema
metadata (#22913)
omit 53e996c43d4 [fix][client] Fix failover consumer-listener stuck with
cumulative ack and epoch time (#23345)
omit adb9014dbac [fix][broker] Fix out-of-order issues with
ConsistentHashingStickyKeyConsumerSelector (#23327)
omit c41c7e944d9 [improve] Configure Rocksdb to use musl libc flavor of the
native library (#23375)
omit 1dad0788c0e [improve][pip] Improve PIP process and voting timeline
(#23387)
omit 50802bea728 [improve][pip] PIP-381: Handle large PositionInfo state
(#23328)
omit d2c91b1e1a8 [fix][broker] Cancel possible pending replay read in
cancelPendingRead (#23384)
omit 9eeffe595b6 [fix][broker] Support large number of unack message store
for cursor recovery (#9292)
omit 5b98d371922 [feat] Use producer name and sequence number as fallback
key in Key_Shared implementation (#23219)
omit e0b754dd393 [improve][broker] check system topic is used before
configuring system topic (ExtensibleLoadManagerImpl only) (#23381)
omit 9980967d777 [improve] Upgrade Pulsar Python client in docker image to
3.5.0 (#23377)
omit 7d7dc80f0ee [fix][broker] Fix the broker registering might be blocked
for long time (#23371)
omit b24285029b1 [improve][ci] Switch to Java 21 as default JVM version for
CI (#23373)
omit 7e59bdeb9d1 [improve] Install openssl in the docker image to fix
compatibility with Apache Pulsar Helm chart (#23362)
omit f071a898775 [fix][cli] Remove deprecated "-client" JVM arg (#23370)
omit 5e832a1cc14 [fix][test] Fix ReplicatorRateLimiterTest (#23369)
omit 950309b57a3 [fix][misc] Log Conscrypt security provider initialization
warnings at debug level (#23364)
omit 77cb67a8c05 [fix][ml] Managed ledger should recover after open ledger
failed (#23368)
omit ca4a7435db6 [fix][build] Disable flaky test
BrokerRegistryIntegrationTest (#23367)
omit 95bd1d1dd3d [fix][broker] Fix the broker registery cannot recover from
the metadata node deletion (#23359)
omit e91574ac7b4 [fix][broker] Fix unloadNamespaceBundlesGracefully can be
stuck with extensible load manager (#23349)
omit 5583102aae1 [fix] [log] Do not print error log if tenant/namespace
does not exist when calling get topic metadata (#23291)
omit b1c5d96ab48 [fix][cli] Fix Pulsar-Client CLI to print metadata of
message including encryption metadata (#23347)
omit 31f27a09192 [fix][cli] Fix Pulsar-Client to allow consume encrypted
messages with appropriate crypto-failure-action (#23346)
omit cefa72c7d18 [improve][schema] Improve Incompatible Schema Exception
error message in ServerCnx.java (#23344)
omit 5ea4252a493 [fix][broker] Avoid introducing delay when there are
delayed messages or marker messages (#23343)
omit 4ce0c752cc4 [fix] Key_Shared mode consumption latency when low traffic
(#23340)
omit 501dfdeace9 [fix][sec] Upgrade vertx to 4.5.10 to address
CVE-2024-8391 (#23338)
omit 7d4ac9dc542 [fix][build] Fix problem where git.commit.id.abbrev is
missing in image tagging (#23337)
omit 216b83008de [fix][test] Fix flaky test
LeaderElectionTest.revalidateLeaderWithinSameSession (#22383)
omit 9012422bcba [improve][broker] Remove ConcurrentOpenHashMap and
ConcurrentOpenHashSet (#23329)
omit 1ce7855c942 [improve][broker] Replace ConcurrentOpenHashMap with
ConcurrentHashMap in Topic classes (#23322)
omit f5c1ad24d77 [improve][broker] Replace ConcurrentOpenHashMap with
ConcurrentHashMap in BrokerService (#23320)
omit c2a0090144a [improve][broker] Add ServiceUnitStateTableView
(ExtensibleLoadManagerImpl only) (#23301)
omit 105192d5baf [fix][broker] Fix topic policies cannot be queried with
extensible load manager (#23326)
omit 4b3b273c1c5 [improve][broker] PIP-376: Make topic policies service
pluggable (#23319)
omit 03330b3f7ca [fix][broker] Fix incomplete NAR file extraction which
prevents broker from starting (#23274)
omit d4261d23824 [improve][broker] Don't use "recently joined consumers"
rules for Key_Shared in STICKY mode (#23275)
omit a875debe914 [fix][io] Upgrade mssql server docker tag in
DebeziumMsSqlContainer (#23318)
omit 77570d5db5f [improve][broker] Add limits for Key_Shared Subscription
look ahead in dispatching (#23231)
omit bf53164c1b0 [improve] Upgrade opensearch sink to client 2.16 and tests
to use server 2.16.0 (#23312)
omit 4f002590450 [improve][admin] PIP-369 Change default value of
`unload-scope` in `ns-isolation-policy set` (#23253)
omit 590e1331d9a [improve][pip] PIP-378 Add ServiceUnitStateTableView
abstraction (ExtensibleLoadMangerImpl only) (#23300)
omit 2e987369fa4 [feat][client] PIP-374: Visibility of messages in
receiverQueue for the consumers (#23303)
omit 9ebd97941d8 [improve][broker] Decouple ManagedLedger interfaces from
the current implementation (#23311)
omit 4f96146f13b [improve][broker] Reducing the parse of MessageMetadata in
compaction (#23285)
omit 13c19b50216 [improve][broker] Register the broker to metadata store
without version id compare (#23298)
omit fc60ec06ae9 [fix][broker] Fail fast if the extensible load manager
failed to start (#23297)
omit 5599699fe41 [improve][pip] PIP-374: Visibility of messages in
receiverQueue for the consumers (#23235)
omit fc0e4e3fe0f [fix] [broker] Fix system topic can not be loaded up if it
contains data offloaded (#23279)
omit 8151639dccb [fix][broker] Fix retry backoff for
PersistentDispatcherMultipleConsumers (#23284)
omit a8ae3e4d191 [improve][pip] PIP-376: Make topic policies service
pluggable (#23248)
omit d4839fb1749 [fix][broker] fix the log format error in the
AdminResource (#23278)
omit a96127a3e0f [feat][meta] Bump oxia java version from 0.3.2 to 0.4.5
(#23277)
omit 96fd04b22f8 [fix] Bump io.grpc from 1.56.0 to 1.56.1 (#23276)
omit 21e256f754b [fix][client] Fix broker/Client CPU reaching 100% during
retriable connection failure (#23251)
omit 0aaa906cd8c [fix][broker] fix pulsar-admin topics stats-internal
caused a BK client thread a deadlock (#23258)
omit 46f99b91145 [improve][broker] Make cluster metadata init command
support metadata config path (#23269)
omit ca0fb443ca9 [fix][broker] Execute the pending callbacks in order
before ready for incoming requests (#23266)
omit 14395295b49 [fix][client] Fix concurrent lookup with properties might
have different results (#23260)
omit 246647fff69 [fix][client] Fix client handle unknown exception during
message-decryption and apply decryption action accordingly (#23256)
omit 6c300f515db [fix][broker] Add principal name into info log to enhance
analysis and troubleshooting (#23257)
omit a28c0df9ba3 [improve][misc] Upgrade Netty to 4.1.113 and
netty-tcnative to 2.0.66 (#23255)
omit de68e2511e0 [improve][broker] Optimize message payload traffic for
ShadowReplicator (#23236)
omit 8bb30a1106e [improve][broker] Add retry for start service unit state
channel (ExtensibleLoadManagerImpl only) (#23230)
omit a678e974e0f [fix][test] Fix flaky
UnloadSubscriptionTest.testMultiConsumer (#23243)
omit aee2ee5070d [fix][broker] Fix brokers still retry start replication
after closed the topic (#23237)
omit 019ae9f0d0e [improve][admin] Improve BrokerStats.allocatorStats
(#23242)
omit 8da3bf8322c [improve][admin] PIP-369 Introduce `unload` flag in
`ns-isolation-policy set` call (#23120)
omit 3a59e4c391d [fix][client] Fix client to handle permits for discarded
and failed decrypt batch-message (#23068)
omit ed14f21de94 [feat][broker] PIP-264: Add replication subscription stats
(#23026)
omit dccc06bf50b [fix][broker] support peek-message for compressed and
encrypted messages (#23234)
omit d98e51f7a54 [improve][broker] Reschedule reads with increasing backoff
when no messages are dispatched (#23226)
omit 59424a831b3 [improve][broker] Add msgInReplay subscription stat and
metric to improve Key_Shared observability (#23224)
omit 587af853fbf [feat][misc] PIP-264: Add OpenTelemetry authentication and
token metrics (#23016)
omit e2bbb4b7cbc [improve][txn] Take first snapshot before persisting the
first transactional message (#21406)
omit 325c6a58d53 [fix][broker] Fix thread unsafe access on the bundle range
cache for load manager (#23217)
omit 9a97c843a46 [feat][broker] PIP-368: Support lookup based on the lookup
properties (#23223)
omit d9bd6b004ed [improve][broker]Change the log level to reduce repeated
error logs (#23192)
omit cd3519aea7c [fix] StatsOutputStream: add string write function (#308)
(#23227)
omit a6029ad2e1b [cleanup][test]delete invalid method in
PrometheusMetricsTest (#23218)
omit 09a16c26974 [improve] [broker] Part 2 of PIP-370: add metrics
"pulsar_replication_disconnected_count" (#23213)
omit 1c495e190b3 [feat] PIP-352: Event time based compaction (#22517)
omit 44f986014e4 [improve] [broker] Phase 1 of PIP-370 support disable
create topics on remote cluster through replication (#23169)
omit 0a5cb51a2f0 [fix] [log] Do not print warn log when concurrently
publishing and switching ledgers (#23209)
omit 66e1a06b247 [improve][client] Don't print info logs for each schema
loaded by client (#23206)
omit b661ec82d20 [improve][broker] Improve pulsar_topic_load_failed metric
to record correct failed time (#23199)
omit 18cb458f73b [improve][broker] Add callback parameters to the
SendCallback.sendComplete (#23196)
omit a605ea32c7e [cleanup] Cleanup some duplicated code (#23204)
omit 94e1341d1e2 [improve][broker] Optimize high CPU usage when consuming
from topics with ongoing txn (#23189)
omit acc463f4b2f [cleanup][broker] delete ConcurrentSortedLongPairSet.
(#23202)
omit 2d46bfafab2 [improve] PIP-337: Implement SSL Factory Plugin to
customize SSL Context and SSL Engine generation (#23110)
omit 9edaa8569de [fix] [broker] Topic can never be loaded up due to broker
maintains a failed topic creation future (#23184)
omit aa8226f45e3 [fix][broker] Skip reading entries from closed cursor.
(#22751)
omit 73433cd06e6 [improve] [broker] Optimize performance for checking max
topics when the topic is a system topic (#23185)
omit 576666de4fd [improve][misc] Set format_version=5, checksum=kxxHash in
Bookkeeper RocksDB configs (#23175)
omit 3053b647e0c [improve][broker] Should notify bundle ownership listener
onLoad event when ServiceUnitState start (ExtensibleLoadManagerImpl only)
(#23152)
omit 7f04364f133 [improve][broker] Support customized shadow managed ledger
implementation (#23179)
omit a1f3322ed35 [fix][test] Fix flaky
SubscriptionSeekTest.testSeekIsByReceive (#23170)
omit b6815d2163b [fix][sec]Upgrade jackson to 2.17.2 (#23174)
omit 3ada56635a6 [feat] Add scripts for updating BK RocksDB ini files
(#23178)
omit 67fc5b9f534 [fix][client] Copy orderingKey to retry letter topic and
DLQ messages and fix bug in copying (#23182)
omit 1f90897c890 [improve] [pip] PIP-370: configurable remote topic
creation in geo-replication (#23124)
omit 46c25ac7342 [fix] DLQ to handle bytes key properly (#23172)
omit 15b88d25081 [fix][broker] Fix shadow topics cannot be consumed when
the entry is not cached (#23147)
omit ce38ee2bccb [improve][pip] PIP-369: Flag based selective unload on
changing ns-isolation-policy (#23116)
omit 606b6a71efd [fix] [test] Revert the modification to
NonDurableSubscriptionTest caused by a mistake in the PR#23129 (#23168)
omit d5ce1cee353 [improve] [broker] Avoid subscription fenced error with
consumer.seek whenever possible (#23163)
omit a0259380e1e [fix][client] Create the retry producer async (#23157)
omit c07b158f003 [fix][client] Fix for early hit `beforeConsume` for
MultiTopicConsumer (#23141)
omit 3e461c004ea [improve][proxy] Reuse authentication instance in
pulsar-proxy (#23113)
omit fe21441f101 [improve] [pip] PIP-363: Add callback parameters to the
method: org.apache.pulsar.client.impl.SendCallback.sendComplete. (#22940)
omit 9bf714ff756 [fix][broker] Fix 'Disabled replicated subscriptions
controller' logic and logging (#23142)
omit 66cc754006c [fix][broker] Fix AvgShedder strategy check (#23156)
omit 06a2f5cc63c [improve] [client]Add new ServiceUrlProvider
implementation: SameAuthParamsAutoClusterFailover (#23129)
omit 2dde4032127 [fix] [broker] Let Pending ack handler can retry to init
when encounters a metadata store error (#23153)
omit 38134bc5ee5 [fix] [meta] Oxia metadta store: Convert error to
MetadataStoreException if operation failed (#23154)
omit 1b43b9de72c [improve][broker] Explicitly close LB internal topics when
playing a follower (ExtensibleLoadManagerImpl only) (#23144)
omit 702c0b3cfa2 [fix] [broker] Fix compatibility issues for PIP-344
(#23136)
omit 6f5c6568ea4 [improve][build] Bump version to 4.0.0-SNAPSHOT (#23146)
omit 4824df5f149 [improve][doc] Add Pulsar Geo-Replication considerations
to the PIP template (#23145)
omit f4a8094f8c7 [fix][metadata] Upgrade Oxia to 0.3.2 (#23140)
omit 3e7dbb4957b [improve][client] Add maxConnectionsPerHost and
connectionMaxIdleSeconds to PulsarAdminBuilder (#22541)
omit 3560ddb64f4 [fix][broker] Fix the bug that elected leader thinks it's
a follower (#23138)
omit 8707fbe8351 [improve][fn] Add support for overriding
additionalJavaRuntimeArguments with PF_additionalJavaRuntimeArguments env
(#23130)
omit 175ea005747 [fix][build] Remove unnecessary Oracle maven repository
from pom.xml (#23132)
omit 3b01c96594a [fix][client] Fix timeout handling in Pulsar Admin client
(#23128)
omit b7440e9023f [improve][pip] PIP-368: Support lookup based on the lookup
properties (#23075)
omit 1db3c5fddce [improve][misc] Optimize TLS performance by omitting extra
buffer copies (#23115)
omit 4a44f457837 [fix][broker] Handle the case when `getOwnedServiceUnits`
fails gracefully (#23119)
omit 114880b1428 [fix][broker]A failed consumer/producer future in
ServerCnx can never be removed (#23123)
omit 10f4e0248f0 [improve][client]PIP-359:Support custom message listener
executor for specific subscription (#22861)
omit 6dd7c59327d [fix][test] Fixed many tests of pulsar-proxy are not
running (#23118)
omit e9deb408eae [improve][misc] Improve AES-GCM cipher performance (#23122)
omit 0e6654788c6 [fix][broker] Fix authenticate order in
AuthenticationProviderList (#23111)
omit 76f16e811be [improve][pip] PIP-366: Support to specify different
config for Configuration and Local Metadata Store (#23041)
omit f3c177e2243 [fix][client] the nullValue in msgMetadata should be true
by default (#22372)
omit 12588a8f30f [fix][broker] type cast on exceptions in exceptionally can
lead to lost calls (#23117)
omit f02ce6c83ee [fix][broker] fix exception may hidden and result in stuck
when topic loading (#23102)
omit 92bcd077c01 [fix][broker]: fix irregular method name (#23108)
omit 9d0292ebb03 [improve][pip] PIP-352: Event time based topic compactor
(#22710)
omit c24953035b8 [improve][broker]Reuse method getAvailableBrokersAsync
(#23099)
omit 5aa5e7d9fbe [fix] [broker] fix replicated namespaces filter in
filterAndUnloadMatchedNamespaceAsync (#23100)
omit 6bbaec1f6b1 [fix][client] TransactionCoordinatorClient support retry
(#23081)
omit 19fe2e40392 [cleanup][broker] Remove PersistentSubscription.getStats
(#23095)
omit 47d35a0af8e [improve][build] Move docker-push profile to submodule
(#23093)
omit b955c6520d8 [fix] [broker] Internal reader of __change_events can not
started after metadata store session rebuilt (#23018)
omit 49d3beb4fae [improve][broker] Support to specify auth-plugin,
auth-parameters and tls-enable arguments when init cluster metadata (#23087)
omit 77b6378ae8b [improve][broker] Optimize the performance of individual
acknowledgments (#23072)
omit 40c8c23123e [improve][broker] Reduce the CPU pressure from the
transaction buffer in rolling restarts (#23062)
omit a0bdf4585fe [improve][ci] Switch to use DEVELOCITY_ACCESS_KEY from
GRADLE_ENTERPRISE_ACCESS_KEY (#23090)
omit 76ed555e7e5 [improve][build] Upgrade docker-maven-plugin to 0.45.0
(#23091)
omit 679a3d49eef [improve] [broker] Check max producers/consumers
limitation first before other ops to save resources (#23074)
omit e59cd05881b [fix] [broker] Remove blocking calls from
Subscription.getStats (#23088)
omit d4bbf10f587 [fix][client] Fix negative acknowledgement by messageId
(#23060)
omit 47f204fb20d [improve][pip] PIP-366: Support to specify different
config for Configuration and Local Metadata Store (#23033)
omit c7310e35d27 [improve] [broker] Add subscription prefix for internal
reader (#23044)
omit 55e468ee412 [fix][broker] Do not try to clean owned bundles from
inactive source brokers (ExtensibleLoadManagerImpl only) (#23064)
omit 38a5e91de9a [fix] Fix compile failing (#23070)
omit 1c53841cc7f [fix][broker] Handle BucketDelayedDeliveryTracker recover
failed (#22735)
omit c9c5bb49b05 [feat][misc] PIP-264: Add OpenTelemetry messaging rate
limit metrics (#23035)
add a2014b6e7f5 [improve][client] Add a producer config to improve
compaction performance
add 08c28534669 ADD TEST
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f56999ae480)
\
N -- N -- N refs/heads/pip/minCompressSize (08c28534669)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 3 -
.github/workflows/ci-maven-cache-update.yaml | 2 +-
.github/workflows/ci-owasp-dependency-check.yaml | 2 +-
.github/workflows/pulsar-ci-flaky.yaml | 2 +-
.github/workflows/pulsar-ci.yaml | 46 +-
.gitignore | 2 -
.mvn/extensions.xml | 2 +-
.mvn/wrapper/maven-wrapper.properties | 9 +-
bin/bookkeeper | 12 +-
bin/function-localrunner | 9 +-
bin/pulsar | 38 +-
bouncy-castle/bc/pom.xml | 2 +-
bouncy-castle/bcfips-include-test/pom.xml | 2 +-
bouncy-castle/bcfips/pom.xml | 2 +-
bouncy-castle/pom.xml | 2 +-
build/run_integration_group.sh | 4 -
build/run_unit_group.sh | 2 +-
buildtools/pom.xml | 4 +-
conf/bkenv.sh | 14 +-
conf/bookkeeper.conf | 9 +-
conf/broker.conf | 56 -
conf/default_rocksdb.conf | 11 +-
conf/entry_location_rocksdb.conf | 6 +-
conf/ledger_metadata_rocksdb.conf | 11 +-
conf/pulsar_env.sh | 13 +-
conf/pulsar_tools_env.sh | 3 +
conf/standalone.conf | 45 -
deployment/terraform-ansible/deploy-pulsar.yaml | 1 +
distribution/io/pom.xml | 2 +-
distribution/io/src/assemble/io.xml | 1 +
distribution/offloaders/pom.xml | 2 +-
distribution/pom.xml | 2 +-
distribution/server/pom.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 245 ++--
distribution/shell/pom.xml | 2 +-
distribution/shell/src/assemble/LICENSE.bin.txt | 117 +-
docker/pom.xml | 3 +-
docker/pulsar-all/pom.xml | 6 +-
docker/pulsar/Dockerfile | 8 +-
docker/pulsar/pom.xml | 7 +-
docker/pulsar/scripts/gen-yml-from-env.py | 3 -
docker/pulsar/scripts/update-ini-from-env.py | 70 -
.../pulsar/scripts/update-rocksdb-conf-from-env.py | 86 --
grafana/dashboards/offloader.json | 599 ---------
jclouds-shaded/pom.xml | 2 +-
jetcd-core-shaded/pom.xml | 2 +-
managed-ledger/pom.xml | 2 +-
.../apache/bookkeeper/mledger/AsyncCallbacks.java | 3 +-
.../apache/bookkeeper/mledger/LedgerOffloader.java | 4 -
.../apache/bookkeeper/mledger/ManagedCursor.java | 15 -
.../apache/bookkeeper/mledger/ManagedLedger.java | 30 -
.../bookkeeper/mledger/ManagedLedgerConfig.java | 20 +-
.../bookkeeper/mledger/ManagedLedgerFactory.java | 12 -
.../bookkeeper/mledger/ReadOnlyManagedLedger.java | 33 -
.../mledger/ReadOnlyManagedLedgerImplWrapper.java | 63 -
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 109 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 434 +------
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 246 ++--
.../mledger/impl/ManagedLedgerOfflineBacklog.java | 380 +++++-
.../bookkeeper/mledger/impl/MetaStoreImpl.java | 9 +-
.../mledger/impl/NonAppendableLedgerOffloader.java | 74 --
.../mledger/impl/NullLedgerOffloader.java | 5 -
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 9 +-
.../bookkeeper/mledger/impl/OpFindNewest.java | 4 +-
.../org/apache/bookkeeper/mledger/impl/OpScan.java | 3 +-
.../impl/OpenTelemetryManagedCursorStats.java | 3 +-
.../impl/OpenTelemetryManagedLedgerStats.java | 5 +-
.../bookkeeper/mledger/impl/RangeSetWrapper.java | 29 -
.../mledger/impl/ReadOnlyCursorImpl.java | 2 +-
.../mledger/impl/ReadOnlyManagedLedgerImpl.java | 8 +-
.../mledger/impl/ShadowManagedLedgerImpl.java | 3 +-
.../mledger/impl/cache/EntryCacheDisabled.java | 4 +-
.../mledger/impl/cache/InflightReadsLimiter.java | 49 +-
.../mledger/impl/cache/RangeEntryCacheImpl.java | 4 +-
.../impl/cache/RangeEntryCacheManagerImpl.java | 5 +-
.../mledger/impl/cache/ReadEntryUtils.java | 54 -
.../intercept/ManagedLedgerInterceptor.java | 57 +-
.../bookkeeper/mledger/offload/OffloaderUtils.java | 2 +-
managed-ledger/src/main/proto/MLDataFormats.proto | 6 -
.../mledger/impl/EntryCacheManagerTest.java | 7 +-
.../bookkeeper/mledger/impl/EntryCacheTest.java | 187 +--
.../mledger/impl/ManagedCursorContainerTest.java | 32 -
.../mledger/impl/ManagedCursorPropertiesTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 97 +-
.../mledger/impl/ManagedLedgerBkTest.java | 47 +-
.../mledger/impl/ManagedLedgerErrorsTest.java | 31 -
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 24 +-
.../mledger/impl/OffloadPrefixReadTest.java | 116 +-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 2 +-
.../impl/ReadOnlyManagedLedgerImplTest.java | 5 +-
.../impl/cache/InflightReadsLimiterTest.java | 86 +-
.../impl/cache/PendingReadsManagerTest.java | 36 +-
.../bookkeeper/test/MockedBookKeeperTestCase.java | 8 +-
microbench/pom.xml | 2 +-
mvnw | 457 ++++---
mvnw.cmd | 287 ++--
pip/README.md | 2 +-
pip/TEMPLATE.md | 14 +-
pip/pip-307.md | 2 +-
pip/pip-324-Alpine Docker images.md | 4 +-
pip/pip-337.md | 6 +-
pip/pip-352.md | 68 -
pip/pip-359.md | 4 +-
pip/pip-360.md | 83 --
pip/pip-363.md | 111 --
pip/pip-366.md | 70 -
pip/pip-367.md | 181 ---
pip/pip-368.md | 185 ---
pip/pip-369.md | 124 --
pip/pip-370.md | 108 --
pip/pip-374.md | 71 -
pip/pip-376-Topic-Policies-Service-Pluggable.md | 222 ----
pip/pip-378.md | 280 ----
pip/pip-379.md | 407 ------
pip/pip-381-large-positioninfo.md | 153 ---
pip/pip-383.md | 144 --
pip/pip-384.md | 158 ---
pom.xml | 205 +--
pulsar-bom/pom.xml | 24 +-
pulsar-broker-auth-athenz/pom.xml | 2 +-
.../AuthenticationProviderAthenz.java | 17 +-
.../AuthenticationProviderAthenzTest.java | 14 +-
pulsar-broker-auth-oidc/pom.xml | 2 +-
.../oidc/AuthenticationProviderOpenID.java | 27 +-
.../broker/authentication/oidc/JwksCache.java | 26 +-
.../oidc/OpenIDProviderMetadataCache.java | 24 +-
...uthenticationProviderOpenIDIntegrationTest.java | 20 +-
.../oidc/AuthenticationProviderOpenIDTest.java | 111 +-
pulsar-broker-auth-sasl/pom.xml | 2 +-
.../authentication/AuthenticationProviderSasl.java | 6 -
.../ProxySaslAuthenticationTest.java | 6 +-
.../authentication/SaslAuthenticateTest.java | 4 +-
pulsar-broker-common/pom.xml | 7 +-
.../pulsar/broker/PulsarServerException.java | 17 -
.../apache/pulsar/broker/ServiceConfiguration.java | 176 +--
.../authentication/AuthenticationProvider.java | 25 -
.../AuthenticationProviderBasic.java | 17 +-
.../authentication/AuthenticationProviderList.java | 59 +-
.../authentication/AuthenticationProviderTls.java | 17 +-
.../AuthenticationProviderToken.java | 47 +-
.../authentication/AuthenticationService.java | 12 +-
.../metrics/AuthenticationMetrics.java | 65 +-
.../metrics/AuthenticationMetricsToken.java | 109 --
.../authorization/AuthorizationProvider.java | 13 -
.../broker/authorization/AuthorizationService.java | 11 -
.../authorization/PulsarAuthorizationProvider.java | 78 --
.../web/plugin/servlet/AdditionalServletUtils.java | 4 +-
.../pulsar/jetty/tls/JettySslContextFactory.java | 58 +-
.../AuthenticationProviderBasicTest.java | 8 +-
.../AuthenticationProviderListTest.java | 5 +-
.../AuthenticationProviderTokenTest.java | 73 +-
.../jetty/tls/JettySslContextFactoryTest.java | 94 +-
.../JettySslContextFactoryWithKeyStoreTest.java | 82 +-
pulsar-broker/pom.xml | 32 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 87 +-
.../apache/pulsar/PulsarInitialNamespaceSetup.java | 11 +-
.../PulsarTransactionCoordinatorMetadataSetup.java | 11 +-
.../pulsar/broker/ManagedLedgerClientFactory.java | 50 +-
.../org/apache/pulsar/broker/PulsarService.java | 118 +-
.../broker/TransactionMetadataStoreService.java | 4 +-
.../apache/pulsar/broker/admin/AdminResource.java | 46 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 65 +-
.../pulsar/broker/admin/impl/ClustersBase.java | 124 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 77 +-
.../broker/admin/impl/PersistentTopicsBase.java | 98 +-
.../broker/admin/impl/SchemasResourceBase.java | 9 -
.../pulsar/broker/admin/v1/SchemasResource.java | 32 -
.../apache/pulsar/broker/admin/v2/Namespaces.java | 44 -
.../broker/admin/v2/NonPersistentTopics.java | 10 +-
.../pulsar/broker/admin/v2/SchemasResource.java | 30 -
.../delayed/AbstractDelayedDeliveryTracker.java | 10 +-
.../BucketDelayedDeliveryTrackerFactory.java | 41 +-
.../broker/delayed/DelayedDeliveryTracker.java | 47 -
.../delayed/DelayedDeliveryTrackerFactory.java | 4 +-
.../delayed/InMemoryDelayedDeliveryTracker.java | 13 +-
.../InMemoryDelayedDeliveryTrackerFactory.java | 23 +-
.../bucket/BookkeeperBucketSnapshotStorage.java | 18 +-
.../bucket/BucketDelayedDeliveryTracker.java | 73 +-
.../delayed/bucket/BucketNotExistException.java | 32 -
.../broker/delayed/bucket/ImmutableBucket.java | 10 +-
.../RecoverDelayedDeliveryTrackerException.java | 25 -
.../broker/intercept/BrokerInterceptorUtils.java | 4 +-
.../intercept/ManagedLedgerInterceptorImpl.java | 62 +-
.../pulsar/broker/loadbalance/LinuxInfoUtils.java | 14 +-
.../pulsar/broker/loadbalance/LoadManager.java | 4 -
.../loadbalance/extensions/BrokerRegistry.java | 11 +-
.../loadbalance/extensions/BrokerRegistryImpl.java | 157 +--
.../extensions/ExtensibleLoadManagerImpl.java | 404 ++----
.../extensions/ExtensibleLoadManagerWrapper.java | 4 -
.../extensions/channel/ServiceUnitState.java | 24 +-
.../channel/ServiceUnitStateChannel.java | 131 +-
.../channel/ServiceUnitStateChannelImpl.java | 741 +++++------
...ava => ServiceUnitStateCompactionStrategy.java} | 24 +-
.../extensions/channel/ServiceUnitStateData.java | 17 +-
...ServiceUnitStateMetadataStoreTableViewImpl.java | 155 ---
.../channel/ServiceUnitStateTableView.java | 113 --
.../channel/ServiceUnitStateTableViewBase.java | 92 --
.../channel/ServiceUnitStateTableViewImpl.java | 190 ---
.../channel/ServiceUnitStateTableViewSyncer.java | 281 ----
.../extensions/data/BrokerLookupData.java | 3 +-
.../filter/BrokerMaxTopicCountFilter.java | 7 +-
.../extensions/store/LoadDataStore.java | 6 -
.../store/TableViewLoadDataStoreImpl.java | 146 +--
.../broker/loadbalance/impl/BundleRangeCache.java | 84 --
.../broker/loadbalance/impl/LoadManagerShared.java | 73 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 50 +-
.../loadbalance/impl/SimpleLoadManagerImpl.java | 33 +-
.../pulsar/broker/lookup/TopicLookupBase.java | 8 +-
.../pulsar/broker/namespace/LookupOptions.java | 2 -
.../pulsar/broker/namespace/NamespaceService.java | 54 +-
.../broker/protocol/ProtocolHandlerUtils.java | 4 +-
.../org/apache/pulsar/broker/rest/TopicsBase.java | 12 +-
.../AbstractDispatcherMultipleConsumers.java | 6 +
.../pulsar/broker/service/AbstractReplicator.java | 16 +-
.../broker/service/AbstractSubscription.java | 46 -
.../pulsar/broker/service/AbstractTopic.java | 64 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 29 +-
.../pulsar/broker/service/BrokerService.java | 595 ++++-----
.../broker/service/BrokerServiceException.java | 6 +
...ConsistentHashingStickyKeyConsumerSelector.java | 275 +---
.../org/apache/pulsar/broker/service/Consumer.java | 272 ++--
.../service/ConsumerHashAssignmentsSnapshot.java | 224 ----
.../broker/service/ConsumerIdentityWrapper.java | 70 -
.../broker/service/ConsumerNameIndexTracker.java | 136 --
.../apache/pulsar/broker/service/Dispatcher.java | 4 +-
.../broker/service/DrainingHashesTracker.java | 353 -----
.../pulsar/broker/service/EntryAndMetadata.java | 43 +-
.../pulsar/broker/service/HashRangeAssignment.java | 26 -
...ashRangeAutoSplitStickyKeyConsumerSelector.java | 67 +-
...ashRangeExclusiveStickyKeyConsumerSelector.java | 35 +-
.../broker/service/ImpactedConsumersResult.java | 59 -
.../pulsar/broker/service/PendingAcksMap.java | 424 ------
.../org/apache/pulsar/broker/service/Producer.java | 20 +-
.../broker/service/PulsarChannelInitializer.java | 94 +-
.../apache/pulsar/broker/service/PulsarStats.java | 5 +-
.../pulsar/broker/service/RemovedHashRanges.java | 91 --
.../apache/pulsar/broker/service/ServerCnx.java | 308 ++---
.../broker/service/ServerCnxThrottleTracker.java | 14 +-
.../broker/service/StickyKeyConsumerSelector.java | 75 +-
.../service/StickyKeyConsumerSelectorUtils.java | 51 -
.../pulsar/broker/service/StickyKeyDispatcher.java | 48 -
.../SystemTopicBasedTopicPoliciesService.java | 272 ++--
.../SystemTopicTxnBufferSnapshotService.java | 15 +-
.../org/apache/pulsar/broker/service/Topic.java | 16 +-
.../broker/service/TopicPoliciesService.java | 193 ++-
.../pulsar/broker/service/TopicPolicyListener.java | 11 +-
.../TransactionBufferSnapshotServiceFactory.java | 26 +-
.../nonpersistent/NonPersistentReplicator.java | 3 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 8 +-
.../nonpersistent/NonPersistentSubscription.java | 7 +-
.../service/nonpersistent/NonPersistentTopic.java | 40 +-
...tractPersistentDispatcherMultipleConsumers.java | 67 -
.../persistent/GeoPersistentReplicator.java | 29 -
.../service/persistent/MessageDeduplication.java | 15 +-
.../persistent/MessageRedeliveryController.java | 68 +-
.../PersistentDispatcherMultipleConsumers.java | 453 ++-----
...rsistentDispatcherMultipleConsumersClassic.java | 1374 --------------------
.../PersistentDispatcherSingleActiveConsumer.java | 26 +-
.../persistent/PersistentMessageExpiryMonitor.java | 46 +-
.../service/persistent/PersistentReplicator.java | 28 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 928 +++++++------
...tickyKeyDispatcherMultipleConsumersClassic.java | 583 ---------
.../service/persistent/PersistentSubscription.java | 225 ++--
.../broker/service/persistent/PersistentTopic.java | 778 +++++------
.../ReplicatedSubscriptionsController.java | 37 +-
.../ReplicatedSubscriptionsSnapshotBuilder.java | 17 +-
.../service/persistent/RescheduleReadHandler.java | 116 --
.../service/persistent/ShadowReplicator.java | 6 +-
.../broker/service/plugin/EntryFilterProvider.java | 4 +-
.../service/schema/BookkeeperSchemaStorage.java | 50 +-
.../broker/stats/AllocatorStatsGenerator.java | 2 -
.../broker/stats/BrokerOperabilityMetrics.java | 18 +-
.../broker/stats/ClusterReplicationMetrics.java | 7 +-
.../OpenTelemetryReplicatedSubscriptionStats.java | 72 -
.../broker/stats/PulsarBrokerOpenTelemetry.java | 5 -
.../broker/stats/metrics/AbstractMetrics.java | 13 +-
.../broker/stats/metrics/ManagedCursorMetrics.java | 13 +-
.../broker/stats/metrics/ManagedLedgerMetrics.java | 22 +-
.../stats/prometheus/AggregatedNamespaceStats.java | 5 -
.../prometheus/AggregatedReplicationStats.java | 3 -
.../prometheus/AggregatedSubscriptionStats.java | 2 -
.../stats/prometheus/NamespaceStatsAggregator.java | 13 +-
.../prometheus/PrometheusMetricsGenerator.java | 21 +-
.../pulsar/broker/stats/prometheus/TopicStats.java | 4 -
.../stats/prometheus/TransactionAggregator.java | 2 +-
.../BookkeeperManagedLedgerStorageClass.java | 42 -
.../broker/storage/ManagedLedgerStorage.java | 36 +-
.../broker/storage/ManagedLedgerStorageClass.java | 45 -
.../NamespaceEventsSystemTopicFactory.java | 8 +-
.../systopic/TopicPoliciesSystemTopicClient.java | 2 -
...sactionBufferSnapshotBaseSystemTopicClient.java | 2 -
.../transaction/buffer/TransactionBuffer.java | 11 +-
.../buffer/impl/InMemTransactionBuffer.java | 2 +-
.../SingleSnapshotAbortedTxnProcessorImpl.java | 78 +-
.../SnapshotSegmentAbortedTxnProcessorImpl.java | 406 +++---
.../broker/transaction/buffer/impl/TableView.java | 97 --
.../buffer/impl/TopicTransactionBuffer.java | 108 +-
.../buffer/impl/TransactionBufferDisable.java | 2 +-
.../pendingack/impl/MLPendingAckStore.java | 6 +-
.../pendingack/impl/MLPendingAckStoreProvider.java | 170 +--
.../pendingack/impl/PendingAckHandleImpl.java | 19 +-
.../org/apache/pulsar/broker/web/WebService.java | 81 +-
.../pulsar/client/impl/RawBatchConverter.java | 57 +-
.../compaction/AbstractTwoPhaseCompactor.java | 439 -------
.../pulsar/compaction/CompactedTopicImpl.java | 14 +-
.../pulsar/compaction/CompactedTopicUtils.java | 14 +-
.../apache/pulsar/compaction/CompactorTool.java | 25 +-
.../EventTimeCompactionServiceFactory.java | 33 -
.../pulsar/compaction/EventTimeOrderCompactor.java | 159 ---
.../compaction/PublishingOrderCompactor.java | 127 --
.../compaction/PulsarCompactionServiceFactory.java | 2 +-
.../compaction/StrategicTwoPhaseCompactor.java | 2 +-
.../pulsar/compaction/TwoPhaseCompactor.java | 470 +++++++
.../utils/ConcurrentBitmapSortedLongPairSet.java | 50 +-
.../java/org/apache/pulsar/utils/SimpleCache.java | 83 --
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 26 +-
.../org/apache/pulsar/broker/BrokerTestUtil.java | 269 +---
.../apache/pulsar/broker/PulsarServiceTest.java | 3 -
...ameAuthParamsLookupAutoClusterFailoverTest.java | 176 ---
.../apache/pulsar/broker/admin/AdminApi2Test.java | 367 +-----
...AdminApiNamespaceIsolationMultiBrokersTest.java | 114 --
.../pulsar/broker/admin/AdminApiOffloadTest.java | 3 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 228 +++-
.../admin/GetPartitionMetadataMultiBrokerTest.java | 88 --
.../broker/admin/GetPartitionMetadataTest.java | 132 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 20 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 84 +-
.../pulsar/broker/admin/TopicAutoCreationTest.java | 2 -
.../pulsar/broker/admin/TopicPoliciesTest.java | 82 +-
.../org/apache/pulsar/broker/admin/TopicsTest.java | 3 -
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 4 +-
.../broker/admin/v3/AdminApiTransactionTest.java | 79 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 10 +-
.../delayed/AbstractDeliveryTrackerTest.java | 18 +-
.../delayed/DelayedDeliveryTrackerFactoryTest.java | 238 ----
.../delayed/InMemoryDeliveryTrackerTest.java | 7 +-
.../pulsar/broker/delayed/MockManagedCursor.java | 31 -
.../bucket/BucketDelayedDeliveryTrackerTest.java | 10 +-
.../intercept/MangedLedgerInterceptorImplTest.java | 6 +-
.../AntiAffinityNamespaceGroupTest.java | 33 +-
.../broker/loadbalance/LoadBalancerTest.java | 12 -
.../broker/loadbalance/SimpleBrokerStartTest.java | 14 -
.../loadbalance/SimpleLoadManagerImplTest.java | 15 -
.../extensions/BrokerRegistryIntegrationTest.java | 129 --
...BrokerRegistryMetadataStoreIntegrationTest.java | 35 -
.../loadbalance/extensions/BrokerRegistryTest.java | 53 +-
.../extensions/ExtensibleLoadManagerCloseTest.java | 58 +-
.../ExtensibleLoadManagerImplBaseTest.java | 60 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 1133 ++++++----------
...LoadManagerImplWithAdvertisedListenersTest.java | 19 +-
...dManagerImplWithTransactionCoordinatorTest.java | 6 +-
.../extensions/LoadManagerFailFastTest.java | 120 --
.../channel/ServiceUnitStateChannelTest.java | 1091 ++++++----------
...=> ServiceUnitStateCompactionStrategyTest.java} | 32 +-
.../extensions/channel/ServiceUnitStateTest.java | 176 +--
.../extensions/data/BrokerLookupDataTest.java | 4 +-
.../extensions/filter/BrokerFilterTestBase.java | 3 +-
.../filter/BrokerIsolationPoliciesFilterTest.java | 3 +-
.../extensions/manager/RedirectManagerTest.java | 4 +-
.../extensions/scheduler/TransferShedderTest.java | 3 +-
.../extensions/store/LoadDataStoreTest.java | 58 +-
.../loadbalance/impl/BundleSplitterTaskTest.java | 11 -
.../loadbalance/impl/LoadManagerSharedTest.java | 45 +-
.../impl/ModularLoadManagerImplTest.java | 18 -
.../namespace/NamespaceOwnershipListenerTests.java | 21 -
.../broker/namespace/NamespaceServiceTest.java | 8 +-
.../broker/service/AbstractReplicatorTest.java | 4 +-
.../pulsar/broker/service/AbstractTopicTest.java | 8 +-
.../pulsar/broker/service/BatchMessageTest.java | 4 +-
.../BatchMessageWithBatchIndexLevelTest.java | 16 +-
.../broker/service/BrokerBkEnsemblesTests.java | 6 +-
.../broker/service/BrokerBookieIsolationTest.java | 6 +-
.../BrokerServiceAutoTopicCreationTest.java | 18 +-
.../pulsar/broker/service/BrokerServiceTest.java | 36 +-
.../service/BrokerServiceThrottlingTest.java | 2 +-
.../CanReconnectZKClientPulsarServiceBaseTest.java | 10 -
.../broker/service/ClusterMigrationTest.java | 12 +-
...istentHashingStickyKeyConsumerSelectorTest.java | 467 +------
.../ConsumerHashAssignmentsSnapshotTest.java | 204 ---
.../service/ConsumerIdentityWrapperTest.java | 68 -
.../service/ConsumerNameIndexTrackerTest.java | 157 ---
.../service/CurrentLedgerRolloverIfFullTest.java | 4 +-
...eateTopicToRemoteClusterForReplicationTest.java | 208 ---
.../broker/service/DrainingHashesTrackerTest.java | 213 ---
...eoReplicationWithConfigurationSyncTestBase.java | 10 -
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 6 +-
.../service/InmemoryTopicPoliciesService.java | 81 --
.../InmemoryTopicPoliciesServiceServiceTest.java | 91 --
.../apache/pulsar/broker/service/Ipv4Proxy.java | 197 ---
.../broker/service/MessageCumulativeAckTest.java | 5 +-
.../service/MessagePublishBufferThrottleTest.java | 102 +-
.../broker/service/NetworkErrorTestBase.java | 307 -----
.../broker/service/OneWayReplicatorTest.java | 176 +--
.../broker/service/OneWayReplicatorTestBase.java | 25 +-
.../service/OneWayReplicatorUsingGlobalZKTest.java | 50 -
.../pulsar/broker/service/PendingAcksMapTest.java | 196 ---
.../PersistentDispatcherFailoverConsumerTest.java | 22 +-
.../service/PersistentTopicConcurrentTest.java | 11 +-
.../broker/service/PersistentTopicE2ETest.java | 123 +-
.../PersistentTopicInitializeDelayTest.java | 4 +-
.../pulsar/broker/service/PersistentTopicTest.java | 155 ++-
.../broker/service/ReplicatedSubscriptionTest.java | 24 +-
.../pulsar/broker/service/ReplicationTxnTest.java | 4 +-
.../broker/service/ReplicatorAdminTlsTest.java | 4 +-
.../ReplicatorAdminTlsWithKeyStoreTest.java | 4 +-
.../broker/service/ReplicatorGlobalNSTest.java | 7 +-
.../broker/service/ReplicatorRateLimiterTest.java | 84 +-
.../pulsar/broker/service/ReplicatorTest.java | 32 +-
.../service/ReplicatorTopicPoliciesTest.java | 18 +-
.../broker/service/ServerCnxNonInjectionTest.java | 62 -
.../pulsar/broker/service/ServerCnxTest.java | 29 +-
.../pulsar/broker/service/StandaloneTest.java | 1 -
.../SubscriptionConsumerCompatibilityTest.java | 175 ---
.../broker/service/SubscriptionSeekTest.java | 102 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 130 +-
.../broker/service/TopicPolicyTestUtils.java | 74 --
.../service/TransactionMarkerDeleteTest.java | 2 +-
.../TransactionalReplicateSubscriptionTest.java | 3 +-
.../pulsar/broker/service/ZkSessionExpireTest.java | 184 ---
.../nonpersistent/NonPersistentTopicTest.java | 3 +-
.../persistent/BucketDelayedDeliveryTest.java | 27 +-
.../service/persistent/DelayedDeliveryTest.java | 8 +-
.../persistent/KeySharedLookAheadConfigTest.java | 63 -
.../service/persistent/MessageDuplicationTest.java | 26 +-
.../MessageRedeliveryControllerTest.java | 4 +-
...tentDispatcherMultipleConsumersClassicTest.java | 172 ---
.../PersistentDispatcherMultipleConsumersTest.java | 71 -
...rsistentDispatcherSingleActiveConsumerTest.java | 127 --
...yKeyDispatcherMultipleConsumersClassicTest.java | 482 -------
...ntStickyKeyDispatcherMultipleConsumersTest.java | 756 ++++++-----
.../persistent/PersistentSubscriptionTest.java | 9 +
.../service/persistent/PersistentTopicTest.java | 3 +-
.../ReplicatedSubscriptionConfigTest.java | 9 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 44 +-
.../persistent/RescheduleReadHandlerTest.java | 161 ---
.../service/persistent/ShadowReplicatorTest.java | 4 +-
.../service/persistent/ShadowTopicRealBkTest.java | 110 --
.../service/persistent/TopicDuplicationTest.java | 9 +-
.../schema/BookkeeperSchemaStorageTest.java | 15 +-
.../broker/service/schema/ClientGetSchemaTest.java | 35 +-
.../stats/AuthenticatedConsumerStatsTest.java | 57 +-
.../broker/stats/BrokerOpenTelemetryTestUtil.java | 1 -
.../pulsar/broker/stats/ConsumerStatsTest.java | 276 +---
.../broker/stats/ManagedLedgerMetricsTest.java | 10 +-
.../broker/stats/MetadataStoreStatsTest.java | 4 +-
.../OpenTelemetryAuthenticationStatsTest.java | 161 ---
.../pulsar/broker/stats/PrometheusMetricsTest.java | 210 ++-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 44 +
.../prometheus/AggregatedNamespaceStatsTest.java | 2 -
.../prometheus/NamespaceStatsAggregatorTest.java | 25 +-
.../NamespaceEventsSystemTopicServiceTest.java | 7 +-
.../systopic/PartitionedSystemTopicTest.java | 4 +-
.../testcontext/NonStartableTestPulsarService.java | 2 +-
.../broker/testcontext/PulsarTestContext.java | 87 +-
.../pulsar/broker/testcontext/SpyConfig.java | 3 -
.../testcontext/StartableTestPulsarService.java | 21 -
.../TopicTransactionBufferRecoverTest.java | 71 +-
.../broker/transaction/TransactionProduceTest.java | 4 +-
.../pulsar/broker/transaction/TransactionTest.java | 32 +-
.../broker/transaction/TransactionTestBase.java | 3 -
.../buffer/TopicTransactionBufferTest.java | 193 +--
.../buffer/TransactionLowWaterMarkTest.java | 16 +-
.../buffer/TransactionStablePositionTest.java | 9 -
.../buffer/utils/TransactionBufferTestImpl.java | 54 -
.../TransactionCoordinatorClientTest.java | 24 -
.../pendingack/PendingAckInMemoryDeleteTest.java | 19 +-
.../pendingack/PendingAckMetadataTest.java | 24 +-
.../pendingack/PendingAckPersistentTest.java | 52 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 8 +-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 52 +-
.../pulsar/client/api/ConsumerRedeliveryTest.java | 24 -
.../pulsar/client/api/DeadLetterTopicTest.java | 120 --
.../client/api/DispatcherBlockConsumerTest.java | 19 +-
.../client/api/InjectedClientCnxClientBuilder.java | 2 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 140 +-
.../client/api/KeySharedSubscriptionTest.java | 1214 +++++++++--------
.../pulsar/client/api/LookupPropertiesTest.java | 153 ---
.../apache/pulsar/client/api/MaxProducerTest.java | 88 --
.../client/api/MessageListenerExecutorTest.java | 193 ---
.../client/api/OrphanPersistentTopicTest.java | 104 +-
.../pulsar/client/api/ProducerConsumerBase.java | 44 +-
.../apache/pulsar/client/api/RetryTopicTest.java | 17 +-
...impleProducerConsumerMLInitializeDelayTest.java | 70 -
.../client/api/SimpleProducerConsumerTest.java | 119 +-
.../SubscriptionMessageDispatchThrottlingTest.java | 18 +-
.../api/SubscriptionPauseOnAckStatPersistTest.java | 7 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 6 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 2 +-
.../pulsar/client/api/UnloadSubscriptionTest.java | 2 -
.../client/api/v1/V1_ProducerConsumerTest.java | 2 +-
.../client/impl/BrokerClientIntegrationTest.java | 55 +-
.../apache/pulsar/client/impl/ClientCnxTest.java | 2 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 34 +-
...eySharedSubscriptionMaxUnackedMessagesTest.java | 285 ----
.../client/impl/KeySharedSubscriptionTest.java | 166 +++
.../pulsar/client/impl/MessageChecksumTest.java | 5 -
.../pulsar/client/impl/MessageRedeliveryTest.java | 66 +-
.../pulsar/client/impl/NegativeAcksTest.java | 13 +-
.../client/impl/ProduceWithMessageIdTest.java | 85 +-
.../client/impl/ProducerConsumerInternalTest.java | 35 +-
.../pulsar/client/impl/PulsarTestClient.java | 2 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 40 -
.../client/impl/SequenceIdWithErrorTest.java | 2 +-
.../client/impl/SimpleProduceConsumeIoTest.java | 134 --
.../apache/pulsar/client/impl/TableViewTest.java | 3 -
.../client/impl/TransactionEndToEndTest.java | 15 +-
.../common/naming/ServiceConfigurationTest.java | 19 -
.../pulsar/compaction/CompactionRetentionTest.java | 4 +-
.../apache/pulsar/compaction/CompactionTest.java | 14 +-
.../apache/pulsar/compaction/CompactorTest.java | 6 +-
.../pulsar/compaction/CompactorToolTest.java | 1 -
.../compaction/EventTimeOrderCompactorTest.java | 201 ---
.../compaction/ServiceUnitStateCompactionTest.java | 29 +-
.../pulsar/compaction/StrategicCompactionTest.java | 4 +-
.../compaction/TopicCompactionServiceTest.java | 4 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 4 +-
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 4 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 26 -
.../pulsar/security/MockedPulsarStandalone.java | 3 -
.../pulsar/tests/KeySharedImplementationType.java | 61 -
.../org/apache/pulsar/utils/SimpleCacheTest.java | 81 --
.../configurations/pulsar_broker_test.conf | 1 -
.../pulsar_broker_test_standalone.conf | 1 -
pulsar-broker/src/test/resources/log4j2.xml | 11 -
pulsar-cli-utils/pom.xml | 2 +-
.../pom.xml | 26 +-
.../pulsar-client-1x}/pom.xml | 52 +-
.../pulsar/client/api/ClientConfiguration.java | 388 ++++++
.../org/apache/pulsar/client/api/Consumer.java | 331 +++++
.../pulsar/client/api/ConsumerConfiguration.java | 411 ++++++
.../apache/pulsar/client/api/MessageBuilder.java | 139 ++
.../apache/pulsar/client/api/MessageListener.java | 56 +
.../org/apache/pulsar/client/api/Producer.java | 199 +++
.../pulsar/client/api/ProducerConfiguration.java | 474 +++++++
.../org/apache/pulsar/client/api/PulsarClient.java | 273 ++++
.../java/org/apache/pulsar/client/api/Reader.java | 81 ++
.../pulsar/client/api/ReaderConfiguration.java | 175 +++
.../apache/pulsar/client/api/ReaderListener.java | 52 +
.../org/apache/pulsar/client/api/package-info.java | 0
.../pulsar/client/impl/MessageBuilderImpl.java | 115 ++
.../apache/pulsar/client/impl/package-info.java | 10 +-
.../pulsar/client/impl/v1/ConsumerV1Impl.java | 176 +++
.../pulsar/client/impl/v1/ProducerV1Impl.java | 90 ++
.../pulsar/client/impl/v1/PulsarClientV1Impl.java | 172 +++
.../apache/pulsar/client/impl/v1/ReaderV1Impl.java | 85 ++
.../apache/pulsar/client/impl/v1/package-info.java | 18 +-
.../src/main/resources/findbugsExclude.xml | 48 +
.../pulsar-client-2x-shaded/pom.xml | 97 ++
pulsar-client-admin-api/pom.xml | 2 +-
.../org/apache/pulsar/client/admin/Brokers.java | 12 +-
.../client/admin/GrantTopicPermissionOptions.java | 36 -
.../org/apache/pulsar/client/admin/Namespaces.java | 28 -
.../pulsar/client/admin/PulsarAdminBuilder.java | 40 -
.../org/apache/pulsar/client/admin/Schemas.java | 16 -
.../pulsar/common/policies/data/ClusterData.java | 8 -
.../pulsar/common/policies/data/ConsumerStats.java | 52 +-
.../pulsar/common/policies/data/DrainingHash.java | 41 -
.../policies/data/ManagedLedgerInternalStats.java | 5 -
.../policies/data/NamespaceIsolationData.java | 4 -
.../data/NamespaceIsolationPolicyUnloadScope.java | 37 -
.../common/policies/data/PersistencePolicies.java | 20 +-
.../common/policies/data/SchemaMetadata.java | 48 -
.../common/policies/data/SubscriptionStats.java | 29 +-
.../apache/pulsar/common/stats/AllocatorStats.java | 2 -
pulsar-client-admin-shaded/pom.xml | 9 +-
pulsar-client-admin/pom.xml | 2 +-
.../pulsar/client/admin/internal/BaseResource.java | 8 +-
.../pulsar/client/admin/internal/BookiesImpl.java | 4 +-
.../client/admin/internal/BrokerStatsImpl.java | 4 +-
.../pulsar/client/admin/internal/BrokersImpl.java | 22 +-
.../pulsar/client/admin/internal/ClustersImpl.java | 4 +-
.../client/admin/internal/ComponentResource.java | 4 +-
.../client/admin/internal/FunctionsImpl.java | 72 +-
.../client/admin/internal/NamespacesImpl.java | 30 +-
.../admin/internal/NonPersistentTopicsImpl.java | 4 +-
.../pulsar/client/admin/internal/PackagesImpl.java | 70 +-
.../client/admin/internal/ProxyStatsImpl.java | 4 +-
.../admin/internal/PulsarAdminBuilderImpl.java | 38 -
.../client/admin/internal/PulsarAdminImpl.java | 46 +-
.../client/admin/internal/ResourceGroupsImpl.java | 4 +-
.../client/admin/internal/ResourceQuotasImpl.java | 4 +-
.../pulsar/client/admin/internal/SchemasImpl.java | 22 +-
.../pulsar/client/admin/internal/SinksImpl.java | 15 +-
.../pulsar/client/admin/internal/SourcesImpl.java | 15 +-
.../pulsar/client/admin/internal/TenantsImpl.java | 4 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 4 +-
.../client/admin/internal/TransactionsImpl.java | 4 +-
.../pulsar/client/admin/internal/WorkerImpl.java | 4 +-
.../admin/internal/http/AsyncHttpConnector.java | 380 ++----
.../internal/http/AsyncHttpRequestExecutor.java | 48 -
.../admin/internal/PulsarAdminBuilderImplTest.java | 2 -
.../internal/http/AsyncHttpConnectorTest.java | 340 -----
pulsar-client-admin/src/test/resources/log4j2.xml | 41 -
pulsar-client-all/pom.xml | 9 +-
pulsar-client-api/pom.xml | 2 +-
.../apache/pulsar/client/api/ClientBuilder.java | 49 +-
.../apache/pulsar/client/api/ConsumerBuilder.java | 31 +-
.../pulsar/client/api/ConsumerInterceptor.java | 38 -
.../apache/pulsar/client/api/ConsumerStats.java | 2 +-
.../pulsar/client/api/MessageListenerExecutor.java | 43 -
.../pulsar/client/api/PulsarClientException.java | 106 +-
.../java/org/apache/pulsar/client/api/Range.java | 37 +-
.../pulsar/client/api/ServiceUrlProvider.java | 2 +-
pulsar-client-auth-athenz/pom.xml | 2 +-
pulsar-client-auth-sasl/pom.xml | 2 +-
pulsar-client-messagecrypto-bc/pom.xml | 2 +-
.../pulsar/client/impl/crypto/MessageCryptoBc.java | 18 +-
pulsar-client-shaded/pom.xml | 7 +-
pulsar-client-tools-api/pom.xml | 2 +-
pulsar-client-tools-customcommand-example/pom.xml | 2 +-
pulsar-client-tools-test/pom.xml | 2 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 4 -
pulsar-client-tools/pom.xml | 7 +-
.../java/org/apache/pulsar/admin/cli/CmdBase.java | 14 +-
.../org/apache/pulsar/admin/cli/CmdClusters.java | 14 -
.../admin/cli/CmdNamespaceIsolationPolicy.java | 17 +-
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 8 +-
.../org/apache/pulsar/admin/cli/CmdSchemas.java | 13 -
.../apache/pulsar/admin/cli/CmdTopicPolicies.java | 8 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 8 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 8 +-
.../cli/utils/CustomCommandFactoryProvider.java | 4 +-
.../pulsar/client/cli/AbstractCmdConsume.java | 45 +-
.../org/apache/pulsar/client/cli/CmdConsume.java | 10 +-
.../java/org/apache/pulsar/client/cli/CmdRead.java | 10 +-
.../apache/pulsar/client/cli/PulsarClientTool.java | 7 -
.../org/apache/pulsar/admin/cli/TestCmdSchema.java | 54 -
pulsar-client/pom.xml | 2 +-
.../client/impl/BatchMessageContainerImpl.java | 12 +-
.../client/impl/BinaryProtoLookupService.java | 115 +-
.../pulsar/client/impl/ClientBuilderImpl.java | 29 -
.../apache/pulsar/client/impl/ConnectionPool.java | 23 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 50 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 10 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 269 ++--
.../pulsar/client/impl/ConsumerInterceptors.java | 32 -
.../org/apache/pulsar/client/impl/HttpClient.java | 126 +-
.../pulsar/client/impl/HttpLookupService.java | 6 +-
.../apache/pulsar/client/impl/LookupService.java | 19 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 17 +-
.../apache/pulsar/client/impl/MessagesImpl.java | 6 -
.../client/impl/MultiTopicsConsumerImpl.java | 72 +-
.../apache/pulsar/client/impl/OpSendMsgStats.java | 38 -
.../pulsar/client/impl/OpSendMsgStatsImpl.java | 73 --
.../client/impl/PartitionedProducerImpl.java | 7 +-
.../apache/pulsar/client/impl/ProducerBase.java | 7 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 52 +-
.../client/impl/PulsarChannelInitializer.java | 148 ++-
.../pulsar/client/impl/PulsarClientImpl.java | 87 +-
.../pulsar/client/impl/ReaderBuilderImpl.java | 3 +-
.../SameAuthParamsLookupAutoClusterFailover.java | 341 -----
.../apache/pulsar/client/impl/SendCallback.java | 5 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 32 +-
.../pulsar/client/impl/TopicListWatcher.java | 11 +-
.../client/impl/TransactionMetaStoreHandler.java | 26 +-
.../client/impl/TypedMessageBuilderImpl.java | 35 +-
.../client/impl/conf/ClientConfigurationData.java | 29 +-
.../impl/conf/ConsumerConfigurationData.java | 3 -
.../impl/schema/reader/MultiVersionAvroReader.java | 8 +-
.../TransactionCoordinatorClientImpl.java | 4 +-
...neFactory.java => WithSNISslEngineFactory.java} | 31 +-
.../org/apache/pulsar/client/api/RangeTest.java | 72 -
.../impl/AcknowledgementsGroupingTrackerTest.java | 4 +-
.../client/impl/AutoClusterFailoverTest.java | 12 +-
.../client/impl/BinaryProtoLookupServiceTest.java | 57 +-
.../pulsar/client/impl/ClientBuilderImplTest.java | 2 +-
.../client/impl/ClientInitializationTest.java | 6 +-
.../client/impl/ControlledClusterFailoverTest.java | 5 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 8 +-
.../pulsar/client/impl/PulsarClientImplTest.java | 6 +-
.../client/impl/TypedMessageBuilderImplTest.java | 17 +-
.../client/impl/UnAckedMessageTrackerTest.java | 7 +-
pulsar-common/pom.xml | 44 +-
.../pulsar/common/naming/SystemTopicNames.java | 5 -
.../org/apache/pulsar/common/nar/NarUnpacker.java | 29 +-
.../common/policies/NamespaceIsolationPolicy.java | 6 -
.../common/policies/data/ClusterDataImpl.java | 28 -
.../policies/data/NamespaceIsolationDataImpl.java | 17 +-
.../policies/data/stats/ConsumerStatsImpl.java | 53 +-
.../policies/data/stats/DrainingHashImpl.java | 46 -
.../policies/data/stats/SubscriptionStatsImpl.java | 30 +-
.../impl/NamespaceIsolationPolicyImpl.java | 8 -
.../apache/pulsar/common/protocol/ByteBufPair.java | 30 -
.../apache/pulsar/common/protocol/Commands.java | 43 +-
.../common/util/DefaultPulsarSslFactory.java | 366 ------
.../common/util/DefaultSslContextBuilder.java | 76 ++
.../org/apache/pulsar/common/util/FieldParser.java | 7 +-
.../util/NettyClientSslContextRefresher.java | 96 ++
.../common/util/NettyServerSslContextBuilder.java | 89 ++
.../pulsar/common/util/ObjectMapperFactory.java | 3 -
.../pulsar/common/util/PulsarSslConfiguration.java | 167 ---
.../pulsar/common/util/PulsarSslFactory.java | 106 --
.../apache/pulsar/common/util/SecurityUtility.java | 8 +-
.../pulsar/common/util/SimpleTextOutputStream.java | 9 -
.../common/util/SslContextAutoRefreshBuilder.java | 100 ++
.../util/collections/ConcurrentOpenHashMap.java | 658 ++++++++++
.../util/collections/ConcurrentOpenHashSet.java | 622 +++++++++
.../ConcurrentOpenLongPairRangeSet.java | 41 -
.../collections/ConcurrentSortedLongPairSet.java | 215 +++
.../common/util/collections/LongPairRangeSet.java | 14 -
.../util/collections/OpenLongPairRangeSet.java | 46 -
.../util/keystoretls/NetSslContextBuilder.java | 90 ++
.../NettySSLContextAutoRefreshBuilder.java | 155 +++
pulsar-common/src/main/proto/PulsarApi.proto | 3 -
.../src/main/resources/findbugsExclude.xml | 5 -
.../pulsar/common/compression/CommandsTest.java | 24 +-
.../apache/pulsar/common/nar/NarUnpackerTest.java | 11 -
.../common/util/DefaultPulsarSslFactoryTest.java | 282 ----
.../common/util/FileModifiedTimeUpdaterTest.java | 24 +-
.../collections/ConcurrentOpenHashMapTest.java | 700 ++++++++++
.../collections/ConcurrentOpenHashSetTest.java | 503 +++++++
.../ConcurrentSortedLongPairSetTest.java | 291 +++++
.../pulsar/common/util/netty/SslContextTest.java | 109 +-
pulsar-config-validation/pom.xml | 2 +-
pulsar-docs-tools/pom.xml | 2 +-
pulsar-functions/api-java/pom.xml | 2 +-
pulsar-functions/instance/pom.xml | 2 +-
pulsar-functions/java-examples-builtin/pom.xml | 2 +-
pulsar-functions/java-examples/pom.xml | 2 +-
pulsar-functions/localrun-shaded/pom.xml | 2 +-
pulsar-functions/localrun/pom.xml | 2 +-
.../org/apache/pulsar/functions/LocalRunner.java | 2 +-
pulsar-functions/pom.xml | 2 +-
pulsar-functions/proto/pom.xml | 2 +-
pulsar-functions/runtime-all/pom.xml | 2 +-
pulsar-functions/runtime/pom.xml | 2 +-
pulsar-functions/secrets/pom.xml | 2 +-
pulsar-functions/utils/pom.xml | 2 +-
.../functions/utils/functions/FunctionUtils.java | 2 +-
.../pulsar/functions/utils/io/ConnectorUtils.java | 2 +-
pulsar-functions/worker/pom.xml | 2 +-
.../pulsar/functions/worker/rest/WorkerServer.java | 86 +-
.../worker/service/WorkerServiceLoader.java | 2 +-
pulsar-io/aerospike/pom.xml | 2 +-
pulsar-io/alluxio/pom.xml | 2 +-
pulsar-io/aws/pom.xml | 2 +-
pulsar-io/azure-data-explorer/pom.xml | 2 +-
pulsar-io/batch-data-generator/pom.xml | 2 +-
pulsar-io/batch-discovery-triggerers/pom.xml | 2 +-
pulsar-io/canal/pom.xml | 2 +-
pulsar-io/cassandra/pom.xml | 2 +-
pulsar-io/common/pom.xml | 2 +-
pulsar-io/core/pom.xml | 2 +-
pulsar-io/data-generator/pom.xml | 2 +-
pulsar-io/debezium/core/pom.xml | 2 +-
pulsar-io/debezium/mongodb/pom.xml | 2 +-
pulsar-io/debezium/mssql/pom.xml | 2 +-
pulsar-io/debezium/mysql/pom.xml | 2 +-
pulsar-io/debezium/oracle/pom.xml | 2 +-
pulsar-io/debezium/pom.xml | 2 +-
pulsar-io/debezium/postgres/pom.xml | 2 +-
pulsar-io/docs/pom.xml | 7 +-
pulsar-io/dynamodb/pom.xml | 2 +-
pulsar-io/elastic-search/pom.xml | 2 +-
.../io/elasticsearch/ElasticSearchConfig.java | 4 +-
.../opensearch/OpenSearchHighLevelRestClient.java | 10 +-
.../io/elasticsearch/ElasticSearchConfigTests.java | 4 +
.../io/elasticsearch/ElasticSearchTestBase.java | 3 +-
.../opensearch/OpenSearchClientSslTests.java | 6 +-
pulsar-io/file/pom.xml | 2 +-
pulsar-io/flume/pom.xml | 2 +-
pulsar-io/hbase/pom.xml | 2 +-
pulsar-io/hdfs2/pom.xml | 130 ++
.../apache/pulsar/io/hdfs2/AbstractHdfsConfig.java | 76 ++
.../pulsar/io/hdfs2/AbstractHdfsConnector.java | 246 ++++
.../org/apache/pulsar/io/hdfs2/Compression.java | 11 +-
.../org/apache/pulsar/io/hdfs2/HdfsResources.java | 51 +
.../org/apache/pulsar/io/hdfs2/SecurityUtil.java | 90 ++
.../org/apache/pulsar/io/hdfs2}/package-info.java | 2 +-
.../pulsar/io/hdfs2/sink/HdfsAbstractSink.java | 124 ++
.../pulsar/io/hdfs2/sink/HdfsSinkConfig.java | 117 ++
.../pulsar/io/hdfs2/sink/HdfsSyncThread.java | 79 ++
.../apache/pulsar/io/hdfs2/sink}/package-info.java | 2 +-
.../sink/seq/HdfsAbstractSequenceFileSink.java | 95 ++
.../io/hdfs2/sink/seq/HdfsSequentialTextSink.java | 70 +
.../pulsar/io/hdfs2/sink/seq/HdfsTextSink.java | 53 +
.../pulsar/io/hdfs2/sink/seq}/package-info.java | 2 +-
.../hdfs2/sink/text/HdfsAbstractTextFileSink.java | 78 ++
.../pulsar/io/hdfs2/sink/text/HdfsStringSink.java | 21 +-
.../pulsar/io/hdfs2/sink/text}/package-info.java | 2 +-
.../resources/META-INF/services/pulsar-io.yaml | 5 +-
.../hdfs2/src/main/resources/findbugsExclude.xml | 58 +
.../pulsar/io/hdfs2/sink/AbstractHdfsSinkTest.java | 120 ++
.../pulsar/io/hdfs2/sink/HdfsSinkConfigTests.java | 158 +++
.../io/hdfs2/sink/seq/HdfsSequentialSinkTests.java | 110 ++
.../io/hdfs2/sink/seq/HdfsTextSinkTests.java | 122 ++
.../io/hdfs2/sink/text/HdfsStringSinkTests.java | 118 ++
.../src/test/resources/hadoop/core-site.xml | 0
.../src/test/resources/hadoop/hdfs-site.xml | 0
.../hdfs2/src/test/resources/sinkConfig.yaml | 8 +-
pulsar-io/hdfs3/pom.xml | 52 +-
pulsar-io/http/pom.xml | 2 +-
pulsar-io/influxdb/pom.xml | 2 +-
pulsar-io/jdbc/clickhouse/pom.xml | 2 +-
pulsar-io/jdbc/core/pom.xml | 2 +-
pulsar-io/jdbc/mariadb/pom.xml | 2 +-
pulsar-io/jdbc/openmldb/pom.xml | 2 +-
pulsar-io/jdbc/pom.xml | 2 +-
pulsar-io/jdbc/postgres/pom.xml | 2 +-
pulsar-io/jdbc/sqlite/pom.xml | 2 +-
pulsar-io/kafka-connect-adaptor-nar/pom.xml | 2 +-
pulsar-io/kafka-connect-adaptor/pom.xml | 2 +-
pulsar-io/kafka/pom.xml | 2 +-
pulsar-io/kinesis/pom.xml | 2 +-
pulsar-io/mongo/pom.xml | 2 +-
pulsar-io/netty/pom.xml | 2 +-
pulsar-io/nsq/pom.xml | 2 +-
pulsar-io/pom.xml | 4 +-
pulsar-io/rabbitmq/pom.xml | 16 +-
.../pulsar/io/rabbitmq/RabbitMQBrokerManager.java | 18 +-
.../pulsar/io/rabbitmq/sink/RabbitMQSinkTest.java | 9 +-
.../io/rabbitmq/source/RabbitMQSourceTest.java | 10 +-
pulsar-io/rabbitmq/src/test/resources/qpid.json | 59 +-
pulsar-io/redis/pom.xml | 2 +-
pulsar-io/solr/pom.xml | 2 +-
pulsar-io/twitter/pom.xml | 2 +-
pulsar-metadata/pom.xml | 2 +-
.../apache/pulsar/metadata/api/MetadataCache.java | 22 +-
.../pulsar/metadata/api/MetadataCacheConfig.java | 12 +-
.../metadata/api/MetadataStoreTableView.java | 87 --
.../metadata/cache/impl/MetadataCacheImpl.java | 37 +-
.../coordination/impl/LeaderElectionImpl.java | 15 +-
.../metadata/impl/AbstractMetadataStore.java | 10 -
.../metadata/impl/PulsarZooKeeperClient.java | 53 +-
.../pulsar/metadata/impl/ZKMetadataStore.java | 2 -
.../metadata/impl/oxia/OxiaMetadataStore.java | 36 +-
.../tableview/impl/MetadataStoreTableViewImpl.java | 342 -----
.../pulsar/metadata/BaseMetadataStoreTest.java | 7 +-
.../apache/pulsar/metadata/LeaderElectionTest.java | 2 -
.../apache/pulsar/metadata/MetadataCacheTest.java | 50 -
.../metadata/MetadataStoreTableViewTest.java | 499 -------
.../apache/pulsar/metadata/MetadataStoreTest.java | 60 +-
.../metadata/OxiaMetadataStoreErrorTest.java | 51 -
.../org/apache/pulsar/metadata/ZKSessionTest.java | 55 -
.../test/resources/zk_client_disabled_sasl.conf | 20 -
pulsar-opentelemetry/pom.xml | 2 +-
.../opentelemetry/OpenTelemetryAttributes.java | 19 -
.../opentelemetry/OpenTelemetryServiceTest.java | 1 -
.../bookkeeper-storage/pom.xml | 2 +-
pulsar-package-management/core/pom.xml | 2 +-
.../filesystem-storage/pom.xml | 2 +-
pulsar-package-management/pom.xml | 2 +-
pulsar-proxy/pom.xml | 2 +-
.../proxy/extensions/ProxyExtensionsUtils.java | 4 +-
.../pulsar/proxy/server/AdminProxyHandler.java | 158 +--
.../pulsar/proxy/server/DirectProxyHandler.java | 86 +-
.../pulsar/proxy/server/LookupProxyHandler.java | 3 +-
.../pulsar/proxy/server/ProxyConfiguration.java | 22 -
.../pulsar/proxy/server/ProxyConnection.java | 2 +-
.../apache/pulsar/proxy/server/ProxyService.java | 25 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 47 +-
.../proxy/server/ServiceChannelInitializer.java | 96 +-
.../org/apache/pulsar/proxy/server/WebServer.java | 86 +-
.../extensions/SimpleProxyExtensionTestBase.java | 12 +-
.../server/AdminProxyHandlerKeystoreTLSTest.java | 13 +-
.../pulsar/proxy/server/AdminProxyHandlerTest.java | 5 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 12 +-
.../proxy/server/FunctionWorkerRoutingTest.java | 10 +-
.../InvalidProxyConfigForAuthorizationTest.java | 3 +-
.../proxy/server/ProxyAdditionalServletTest.java | 15 +-
.../ProxyAuthenticatedProducerConsumerTest.java | 11 +-
.../proxy/server/ProxyAuthenticationTest.java | 7 +-
.../server/ProxyConnectionThrottlingTest.java | 11 +-
.../proxy/server/ProxyDisableZeroCopyTest.java | 2 +-
.../server/ProxyEnableHAProxyProtocolTest.java | 12 +-
.../proxy/server/ProxyForwardAuthDataTest.java | 10 +-
.../pulsar/proxy/server/ProxyIsAHttpProxyTest.java | 59 +-
.../server/ProxyKeyStoreTlsTransportTest.java | 12 +-
.../proxy/server/ProxyKeyStoreTlsWithAuthTest.java | 12 +-
.../server/ProxyKeyStoreTlsWithoutAuthTest.java | 12 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 11 +-
.../pulsar/proxy/server/ProxyMutualTlsTest.java | 12 +-
.../pulsar/proxy/server/ProxyParserTest.java | 13 +-
.../proxy/server/ProxyPrometheusMetricsTest.java | 15 +-
.../pulsar/proxy/server/ProxyRefreshAuthTest.java | 12 +-
.../proxy/server/ProxyRolesEnforcementTest.java | 9 +-
.../proxy/server/ProxyServiceStarterTest.java | 91 --
.../proxy/server/ProxyServiceTlsStarterTest.java | 2 -
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 14 +-
.../proxy/server/ProxyStuckConnectionTest.java | 12 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 106 +-
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 12 +-
.../pulsar/proxy/server/ProxyTlsWithAuthTest.java | 12 +-
.../server/ProxyWithAuthorizationNegTest.java | 10 +-
.../proxy/server/ProxyWithAuthorizationTest.java | 19 +-
.../server/ProxyWithExtensibleLoadManagerTest.java | 11 +-
.../server/ProxyWithJwtAuthorizationTest.java | 18 +-
.../server/ProxyWithoutServiceDiscoveryTest.java | 11 +-
.../SuperUserAuthedAdminProxyHandlerTest.java | 12 +-
.../server/UnauthedAdminProxyHandlerTest.java | 16 +-
pulsar-testclient/pom.xml | 2 +-
.../apache/pulsar/testclient/PerfClientUtils.java | 10 -
.../testclient/PerformanceBaseArguments.java | 9 -
.../pulsar/testclient/PerformanceProducerTest.java | 42 +-
pulsar-transaction/common/pom.xml | 2 +-
pulsar-transaction/coordinator/pom.xml | 36 +-
.../impl/MLTransactionSequenceIdGenerator.java | 58 +-
pulsar-transaction/pom.xml | 2 +-
pulsar-websocket/pom.xml | 2 +-
.../apache/pulsar/websocket/WebSocketService.java | 36 +-
.../pulsar/websocket/service/ProxyServer.java | 84 +-
.../apache/pulsar/websocket/stats/ProxyStats.java | 7 +-
structured-event-log/pom.xml | 2 +-
testmocks/pom.xml | 2 +-
tests/bc_2_0_0/pom.xml | 2 +-
tests/bc_2_0_1/pom.xml | 2 +-
tests/bc_2_6_0/pom.xml | 2 +-
tests/docker-images/java-test-functions/pom.xml | 2 +-
tests/docker-images/java-test-image/pom.xml | 2 +-
tests/docker-images/java-test-plugins/pom.xml | 2 +-
tests/docker-images/latest-version-image/pom.xml | 2 +-
tests/docker-images/pom.xml | 2 +-
tests/integration/pom.xml | 2 +-
.../containers/DebeziumMsSqlContainer.java | 2 +-
.../integration/containers/PulsarContainer.java | 5 -
.../integration/io/sinks/OpenSearchSinkTester.java | 3 +-
.../debezium/DebeziumMsSqlSourceTester.java | 2 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 48 +-
.../tests/integration/messaging/MessagingBase.java | 7 +-
.../integration/topologies/PulsarCluster.java | 58 +-
.../integration/topologies/PulsarClusterSpec.java | 6 -
.../topologies/PulsarClusterTestBase.java | 6 +-
.../upgrade/PulsarUpgradeDowngradeTest.java | 175 ---
.../src/test/resources/pulsar-upgrade.xml | 2 +-
tests/pom.xml | 2 +-
tests/pulsar-client-admin-shade-test/pom.xml | 2 +-
tests/pulsar-client-all-shade-test/pom.xml | 2 +-
tests/pulsar-client-shade-test/pom.xml | 2 +-
tiered-storage/file-system/pom.xml | 14 +-
tiered-storage/jcloud/pom.xml | 2 +-
.../offload/jcloud/impl/MockManagedLedger.java | 55 +-
.../AbstractJCloudBlobStoreFactoryTest.java | 6 +-
tiered-storage/pom.xml | 2 +-
933 files changed, 20486 insertions(+), 38544 deletions(-)
delete mode 100755 docker/pulsar/scripts/update-ini-from-env.py
delete mode 100755 docker/pulsar/scripts/update-rocksdb-conf-from-env.py
delete mode 100644 grafana/dashboards/offloader.json
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ReadOnlyManagedLedger.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ReadOnlyManagedLedgerImplWrapper.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonAppendableLedgerOffloader.java
delete mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/ReadEntryUtils.java
delete mode 100644 pip/pip-352.md
delete mode 100644 pip/pip-360.md
delete mode 100644 pip/pip-363.md
delete mode 100644 pip/pip-366.md
delete mode 100644 pip/pip-367.md
delete mode 100644 pip/pip-368.md
delete mode 100644 pip/pip-369.md
delete mode 100644 pip/pip-370.md
delete mode 100644 pip/pip-374.md
delete mode 100644 pip/pip-376-Topic-Policies-Service-Pluggable.md
delete mode 100644 pip/pip-378.md
delete mode 100644 pip/pip-379.md
delete mode 100644 pip/pip-381-large-positioninfo.md
delete mode 100644 pip/pip-383.md
delete mode 100644 pip/pip-384.md
delete mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/metrics/AuthenticationMetricsToken.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketNotExistException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/RecoverDelayedDeliveryTrackerException.java
rename
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/{ServiceUnitStateDataConflictResolver.java
=> ServiceUnitStateCompactionStrategy.java} (82%)
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateMetadataStoreTableViewImpl.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableView.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewBase.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewImpl.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewSyncer.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleRangeCache.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerIdentityWrapper.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerNameIndexTracker.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAssignment.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ImpactedConsumersResult.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PendingAcksMap.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RemovedHashRanges.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelectorUtils.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyDispatcher.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/AbstractPersistentDispatcherMultipleConsumers.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassic.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/RescheduleReadHandler.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryReplicatedSubscriptionStats.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/storage/BookkeeperManagedLedgerStorageClass.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/storage/ManagedLedgerStorageClass.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/AbstractTwoPhaseCompactor.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeCompactionServiceFactory.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeOrderCompactor.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/PublishingOrderCompactor.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/TwoPhaseCompactor.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/utils/SimpleCache.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiNamespaceIsolationMultiBrokersTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/DelayedDeliveryTrackerFactoryTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryMetadataStoreIntegrationTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/LoadManagerFailFastTest.java
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/channel/{ServiceUnitStateDataConflictResolverTest.java
=> ServiceUnitStateCompactionStrategyTest.java} (88%)
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshotTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerIdentityWrapperTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerNameIndexTrackerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DrainingHashesTrackerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/InmemoryTopicPoliciesService.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/InmemoryTopicPoliciesServiceServiceTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/Ipv4Proxy.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NetworkErrorTestBase.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PendingAcksMapTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxNonInjectionTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionConsumerCompatibilityTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicPolicyTestUtils.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/KeySharedLookAheadConfigTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassicTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassicTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/RescheduleReadHandlerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/ShadowTopicRealBkTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/OpenTelemetryAuthenticationStatsTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/utils/TransactionBufferTestImpl.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/LookupPropertiesTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MaxProducerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MessageListenerExecutorTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeySharedSubscriptionMaxUnackedMessagesTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeySharedSubscriptionTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/SimpleProduceConsumeIoTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/compaction/EventTimeOrderCompactorTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/tests/KeySharedImplementationType.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/utils/SimpleCacheTest.java
copy {pulsar-transaction => pulsar-client-1x-base}/pom.xml (77%)
copy {pulsar-functions/java-examples =>
pulsar-client-1x-base/pulsar-client-1x}/pom.xml (72%)
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ClientConfiguration.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Consumer.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ConsumerConfiguration.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/MessageBuilder.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/MessageListener.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Producer.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ProducerConfiguration.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/PulsarClient.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Reader.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ReaderConfiguration.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/ReaderListener.java
copy {pulsar-client-api =>
pulsar-client-1x-base/pulsar-client-1x}/src/main/java/org/apache/pulsar/client/api/package-info.java
(100%)
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/MessageBuilderImpl.java
rename
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/PositionBound.java
=>
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/package-info.java
(82%)
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/v1/ConsumerV1Impl.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/v1/ProducerV1Impl.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/v1/PulsarClientV1Impl.java
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/v1/ReaderV1Impl.java
rename
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/RevokeTopicPermissionOptions.java
=>
pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/impl/v1/package-info.java
(79%)
create mode 100644
pulsar-client-1x-base/pulsar-client-1x/src/main/resources/findbugsExclude.xml
create mode 100644 pulsar-client-1x-base/pulsar-client-2x-shaded/pom.xml
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/GrantTopicPermissionOptions.java
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/DrainingHash.java
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/NamespaceIsolationPolicyUnloadScope.java
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SchemaMetadata.java
delete mode 100644
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpRequestExecutor.java
delete mode 100644
pulsar-client-admin/src/test/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorTest.java
delete mode 100644 pulsar-client-admin/src/test/resources/log4j2.xml
delete mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageListenerExecutor.java
delete mode 100644
pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSchema.java
delete mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/OpSendMsgStats.java
delete mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/OpSendMsgStatsImpl.java
delete mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java
rename
pulsar-client/src/main/java/org/apache/pulsar/client/util/{PulsarHttpAsyncSslEngineFactory.java
=> WithSNISslEngineFactory.java} (53%)
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/DrainingHashImpl.java
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/DefaultPulsarSslFactory.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/DefaultSslContextBuilder.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/NettyClientSslContextRefresher.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/NettyServerSslContextBuilder.java
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/PulsarSslConfiguration.java
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/PulsarSslFactory.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/SslContextAutoRefreshBuilder.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashMap.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashSet.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentSortedLongPairSet.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/NetSslContextBuilder.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/NettySSLContextAutoRefreshBuilder.java
delete mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/DefaultPulsarSslFactoryTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashMapTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentOpenHashSetTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentSortedLongPairSetTest.java
create mode 100644 pulsar-io/hdfs2/pom.xml
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java
rename
pulsar-broker/src/main/java/org/apache/pulsar/compaction/MessageCompactionData.java
=> pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/Compression.java
(80%)
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/HdfsResources.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/SecurityUtil.java
copy {pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl
=> pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2}/package-info.java
(94%)
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java
copy {pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl
=>
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink}/package-info.java
(94%)
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialTextSink.java
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSink.java
copy {pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl
=>
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq}/package-info.java
(94%)
create mode 100644
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsAbstractTextFileSink.java
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/utils/TransactionBufferTestProvider.java
=>
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsStringSink.java
(60%)
rename
{pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl =>
pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text}/package-info.java
(94%)
rename pulsar-broker/src/test/resources/conf/zk_client_enable_sasl.conf =>
pulsar-io/hdfs2/src/main/resources/META-INF/services/pulsar-io.yaml (81%)
create mode 100644 pulsar-io/hdfs2/src/main/resources/findbugsExclude.xml
create mode 100644
pulsar-io/hdfs2/src/test/java/org/apache/pulsar/io/hdfs2/sink/AbstractHdfsSinkTest.java
create mode 100644
pulsar-io/hdfs2/src/test/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfigTests.java
create mode 100644
pulsar-io/hdfs2/src/test/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialSinkTests.java
create mode 100644
pulsar-io/hdfs2/src/test/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSinkTests.java
create mode 100644
pulsar-io/hdfs2/src/test/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsStringSinkTests.java
copy pulsar-io/{hdfs3 => hdfs2}/src/test/resources/hadoop/core-site.xml (100%)
copy pulsar-io/{hdfs3 => hdfs2}/src/test/resources/hadoop/hdfs-site.xml (100%)
rename pulsar-metadata/src/test/resources/oxia_client.conf =>
pulsar-io/hdfs2/src/test/resources/sinkConfig.yaml (83%)
delete mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreTableView.java
delete mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java
delete mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataStoreTableViewTest.java
delete mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/OxiaMetadataStoreErrorTest.java
delete mode 100644
pulsar-metadata/src/test/resources/zk_client_disabled_sasl.conf
delete mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/upgrade/PulsarUpgradeDowngradeTest.java
