Sync master-aligned delayed delivery & cursor persistence work into branch-as-4.0 (CI verification) - #98

Closed

nodece wants to merge 213 commits into

branch-as-4.0from

branch-as-4.0-08282121

Commits on Aug 28, 2026

[improve][client] In cases where there is a risk of message loss, adjust the log level to error (#25854)

poorbarcode
authored and
nodece
committed
6f1a023
[fix][client]Fix checkstyle issue of ConsumerBase.java

poorbarcode
authored and
nodece
committed
e2ae742
[fix][client] Fix failed to close consumer because of the error: param memorySize is a negative value (#25805)

poorbarcode
authored and
nodece
committed
6891dff
[fix][sec] Upgrade commons-configuration2 to 2.15.0 to address CVE-2026-45205 (#25844)

lhotari
authored and
nodece
committed
59a1bfd
[improve][misc] Upgrade Netty to 4.1.134 (#25870)

lhotari
authored and
nodece
committed
7fd4287
[fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests (#25867)

Dream95
authored and
nodece
committed
b7b57e0
[fix][test] Fix flaky ProducerCleanupTest timer cleanup (#25864)

oneby-wang
authored and
nodece
committed
cd7feee
[fix][test] Fix flaky PulsarFunctionTlsTest.testFunctionsCreation() test (#25889)

oneby-wang
authored and
nodece
committed
58e03d6
[fix][broker] Fix compaction cursor reset may lose mark-delete properties (#25862)

oneby-wang
authored and
nodece
committed
5e53836
Return 400 for invalid reader messageId query parameter (#25865)

pratt4
authored and
nodece
committed
e533a3c
[fix][broker] Fix PersistentMessageExpiryMonitor findEntryComplete() method may lose mark-delete properties in race condition (#25803)

oneby-wang
authored and
nodece
committed
7e75bb9
[fix][bk] Fix NPE in IsolatedBookieEnsemblePlacementPolicy when policy class does not match (#25825)

authored and
nodece
committed
ea9bbae
[fix][broker] Fix non-batched null-value messages not removed during topic compaction (#25817)

grishaf
authored and
nodece
committed
5e35087
[improve][client] Best-effort retry for individual/batch-index acks on send failure when ackReceiptEnabled=false (#25525)

nodece
and
Copilot
committed
adaffc9
[fix][broker] Fix precision loss in DataSketchesSummaryLogger by replacing LongAdder with DoubleAdder for sum accumulation (#25594)

zjxxzjwang
authored and
nodece
committed
ecd51a2
[fix][broker] Fix stuck chunks in SharedConsumerAssignor permit tracking (#25620)

merlimat
authored and
nodece
committed
462ee2b
[fix][client] Fix stale Healthy state in SameAuthParamsLookupAutoClusterFailover causing flaky test (#25388)

authored and
nodece
committed
7ff3067
[fix][client] Reset higher-index states on recovery in SameAuthParamsLookupAutoClusterFailover (#25826)

merlimat
authored and
nodece
committed
7b9afeb
[fix][test][branch-4.0] Fix PersistentMessageExpiryMonitorTest

lhotari
authored and
nodece
committed
41a0dda
[fix][test] Fix flaky MessagePublishBufferThrottleTest.testBlockByPublishRateLimiting (#25365)

merlimat
authored and
nodece
committed
b06d879
[fix][test][branch-4.0] Fix PulsarFunctionTlsTest

lhotari
authored and
nodece
committed
118de6c
[fix][test] Fix flaky testMsgDropStat in NonPersistentTopicTest (#25426)

merlimat
authored and
nodece
committed
ae547c6
[improve][broker] PIP-380: Support-setting-up-specific-namespaces-to-skipping-the-load-shedding (#23549)

Demogorgon314
authored and
nodece
committed
3733db2
[fix][meta] Fix PulsarZooKeeperClient async addWatch callback retry behavior (#25913)

oneby-wang
authored and
nodece
committed
346bc30
[fix][meta] Fix ZooKeeper session reconnect race condition in PulsarZooKeeperClient.clientCreator (#25910)

oneby-wang
authored and
nodece
committed
6593c77
[fix][test] Fix flaky SameAuthParamsLookupAutoClusterFailoverTest.testAutoClusterFailover() test (#25892)

oneby-wang
authored and
nodece
committed
2820ef4
[improve][fn] make built-in functions reload incremental (#25868)

pratt4
authored and
nodece
committed
1ee0ea7
[fix][sec] Upgrade Netty to 4.1.135.Final to address several CVEs (#25918)

lhotari
authored and
nodece
committed
f053c97
[fix][client] Clean up unacked messages when unsubscribing a topic with ack timeout backoff (#25916)

Dream95
authored and
nodece
committed
baa63c6
[improve][proxy][branch-4.0] Restore AdminProxyHandler changes which were accidentially reverted in Jetty 12 upgrade

lhotari
authored and
nodece
committed
41a8708
[fix][proxy] Avoid intermittent 502 when admin proxy follows a broker redirect for a request with a body (#25919)

lhotari
authored and
nodece
committed
016d101
[fix][client] Prevent duplicate ServiceUrlProvider initialization (#25899)

oneby-wang
authored and
nodece
committed
309fcf8
[improve][offload] Coalesce automatic offload triggers to reduce retry loops and ledger scans (#25793)

void-ptr974
authored and
nodece
committed
55fd834
[fix][test] Stabilize testSecondaryIsolationGroupsBookiesNegative() test (#25900)

oneby-wang
authored and
nodece
committed
5378869
[improve][misc] Upgrade vert.x to 4.5.28 (#25924)

lhotari
authored and
nodece
committed
27544e1
[improve][functions] Allow customizing Kubernetes service domain suffix in Function Worker (#25872)

authored and
nodece
committed
067e432
[fix][client] Match logical topic when removing unacked messages (#25921)

Dream95
authored and
nodece
committed
77790df
[improve][client] Clean up unacked message tracker when topics are removed in multi-topic consumers (#25923)

Dream95
authored and
nodece
committed
eb3bf78
[fix][client] Preserve equals in FieldParser map values (#25907)

hiSandog
authored and
nodece
committed
2facacd
[fix][fn] Fix orphan exclusive producer on creation timeout in WorkerUtils.createExclusiveProducerWithRetry (#25942)

lhotari
authored and
nodece
committed
5ad246c
[improve][misc] Upgrade Jetty to 12.1.10 (#25943)

lhotari
authored and
nodece
committed
b42a2ec
[feat][pip] PIP-469: Legacy-aware topic policies backend routing and metadata-store topic policies (#25547)

BewareMyPower
authored and
nodece
committed
bba285f
[feat][broker] PIP-469: Legacy-aware topic policies backend routing and metadata-store topic policies (#25707)

BewareMyPower
authored and
nodece
committed
a5e33ec
Fix build failure due to an old version of Caffine

BewareMyPower
authored and
nodece
committed
1885cf1
[fix][broker] Fix tableview divergence in ServiceUnitStateTableViewSyncer causing flaky tests (#25946)

lhotari
authored and
nodece
committed
500d85c
[fix][test] Fix flaky ExtensibleLoadManagerImplTest by re-serving the channel topic in initializeState (#25976)

merlimat
authored and
nodece
committed
e5254fd
[fix][test] Fix flaky ExtensibleLoadManagerImplTest.initializeState by recovering wedged channel ownership (#25977)

lhotari
authored and
nodece
committed
0b27005
[fix][test] Deflake TopicPoliciesTest.setupTestTopic by retrying forced namespace deletion (#25974)

lhotari
authored and
nodece
committed
c2f68c6
[improve][misc] Upgrade Apache Commons libraries and Apache Http components (#25963)

lhotari
authored and
nodece
committed
73dd67e
[fix][test][branch-4.0] Backport configurable read/add delays in PulsarMockBookKeeper

lhotari
authored and
nodece
committed
4b69157
[fix][broker] Fix compacted read could be stuck forever or message loss due to cursor mark delete (#25998)

BewareMyPower
authored and
nodece
committed
59e61eb
[fix][meta] Keep the leader value in the election cycle and make leader reads authoritative (#26000)

lhotari
authored and
nodece
committed
966c957
[fix][build][branch-4.0] Upgrade docker/setup-qemu-action to v4.1.0

lhotari
authored and
nodece
committed
609cbfb
[fix][broker] Prevent subscribe rate limit from stalling compaction and blocking forced deletion (#26015)

lhotari
authored and
nodece
committed
8ad9d84
[fix][broker] Fix forced topic/namespace deletion hanging or failing when compaction is in progress (#26016)

lhotari
authored and
nodece
committed
4571d0d
[fix][broker] Fix forced topic/namespace deletion still hanging when the compaction reader reconnect stalls (#26026)

lhotari
authored and
nodece
committed
ab89028
[fix][broker] Don't let a stuck or aborted topic policies cache init make a namespace's topics unloadable (#26025)

lhotari
authored and
nodece
committed
d703fd0
[fix][broker] Fail fast for load balancer misconfigurations instead of falling back to SimpleLoadManagerImpl (#26031)

BewareMyPower
authored and
nodece
committed
195e431
[improve][fn] Upgrade pulsar-client-python to 3.12.0 (#26033)

lhotari
authored and
nodece
committed
d5ba72b
[fix][fn] Make exclusiveLeaderProducer volatile in FunctionMetaDataManager (#26046)

authored and
nodece
committed
b70749c
[fix][broker] Run topic policy notifications on the topic-ordered executor (#26042)

lhotari
authored and
nodece
committed
486ab38
[fix][test] Fix flaky testPrepareInitPoliciesCacheAsyncThrowExceptionAfterCreateReader (#26049)

lhotari
authored and
nodece
committed
5de8b35
[fix][broker] Prevent topic policy initialization race with a buffering listener wrapper (#26044)

lhotari
authored and
nodece
committed
97b9b9a
[fix][broker] Avoid blocking metadata read on the IO thread when redirecting migrated producers/consumers (#26051)

merlimat
authored and
nodece
committed
204a7e5
[fix][proxy] Avoid blocking the proxy IO thread on a cold broker cache (#26052)

merlimat
authored and
nodece
committed
2e349ed
[fix][broker] Avoid blocking the dispatcher close path on delayed-delivery tracker close (#26053)

merlimat
authored and
nodece
committed
7d796f4
[fix][broker] Avoid blocking the bundle-throughput lookup on per-bundle metadata reads (#26054)

merlimat
authored and
nodece
committed
8a1b607
[fix][sec] Upgrade jline to 4.2.1 and picocli to 4.7.7, drop unused jline2 (#26068)

lhotari
authored and
nodece
committed
26d95f2
[fix] functions: Run worker leader-election off the consumer event-listener thread (#26059)

merlimat
authored and
nodece
committed
44eda75
[fix][broker] Fix geo-replication stuck after a failed publish to the remote cluster (#26002)

void-ptr974
authored and
nodece
committed
98bed5a
[improve][test]Add test: test/testTopicPartitionCannotBeCreatedAfterTopicDeleted (#26038)

poorbarcode
authored and
nodece
committed
d8a3793
[fix][test] Make SameAuthParamsLookupAutoClusterFailoverTest less timing-sensitive (#25675)

merlimat
authored and
nodece
committed
a0e1e28
[fix][client] Run the failover health probe off the Netty event-loop thread (#26064)

merlimat
authored and
nodece
committed
28ac97e
[fix][meta] Run ledger-underreplication notification callbacks off the metadata-store listener thread (#26065)

merlimat
authored and
nodece
committed
e3be3e2
[fix][broker] Avoid attaching a consumer to a migrated non-persistent topic on subscribe (#26075)

lhotari
authored and
nodece
committed
dc9c894
[feat][broker] Expose managed ledger properties via topic internal stats (#26079)

BewareMyPower
authored and
nodece
committed
a8c0ba4
[fix][broker]Do not trigger topic GC if replication is still active (#25915)

poorbarcode
authored and
nodece
committed
591151a
[fix][sec][branch-4.0] Upgrade Jackson version to 2.18.8 (#26098)

shibd
authored and
nodece
committed
b321014
[improve][broker] Trim orphaned bucket snapshots when ledgers are deleted (#25984)

dao-jun
authored and
nodece
committed
be4b387
[fix][broker] Guard BucketDelayedDeliveryTracker.nextDeliveryTime against empty queues (#26080)

dao-jun
authored and
nodece
committed
af42891
[improve][broker] Improve dispatch performance by summing entry bytes with a loop (#26055)

void-ptr974
authored and
nodece
committed
64088b0
[fix][broker] Fix replicator getting stuck under rate limiter throttling and honor readBatchSize/maxReadSizeBytes on the default read path (#26005)

authored and
nodece
committed
c915175
[fix][broker] Forward topic policy updates after init failures (#26110)

Denovo1998
authored and
nodece
committed
5cdb612
[fix][test][branch-4.0] Adapt ConfigurationDataUtilsTest to Jackson 2.18.8 InetSocketAddress deserialization

lhotari
authored and
nodece
committed
1fa3098
Revert "[improve][test]Add test: test/testTopicPartitionCannotBeCreatedAfterTopicDeleted (#26038)"

lhotari
authored and
nodece
committed
d92f4c4
[fix][broker] Fix replication stall when a cursor rewind skips an in-flight read (#26106)

lhotari
authored and
nodece
committed
3cf56d8
[fix][test] Fix flaky AuditorBookieTest.testBookieClusterRestart (#26122)

lhotari
authored and
nodece
committed
c797c36
[fix][test] Fix flaky SchemaServiceTest.testSchemaRegistryMetrics (#25645)

merlimat
authored and
nodece
committed
d47c4b3
[fix][test] Fix flaky PersistentTopicsTest setup caused by concurrent Mockito stubbing (#26083)

void-ptr974
authored and
nodece
committed
29fcd20
[fix][test] Run makeReadEntryProbFail's errorOrNot on a caller-provided executor (#26123)

lhotari
authored and
nodece
committed
c2aad8d
[fix][broker] Don't let a closing topic-policies reader abort a concurrent cache-init reload (#26132)

lhotari
authored and
nodece
committed
50c4c93
[improve][broker] Load topic policies on non-persistent topic load and gate the policy replay (#26134)

lhotari
authored and
nodece
committed
1a4598d
[improve][fn] Upgrade pulsar-client-python to 3.13.0 (#26139)

lhotari
authored and
nodece
committed
4643139
[fix][sec] Upgrade pulsar-client-go to v0.20.0 in pulsar-function-go, also address CVEs (#26140)

lhotari
authored and
nodece
committed
ab3aa71
[fix][fn] Reorder Function Worker shutdown to stop scheduler before runtime manager (#26136)

Dream95
authored and
nodece
committed
c0af19d
[fix][sec] Bump github.com/go-jose/go-jose/v4 from 4.1.3 to 4.1.4 in /pulsar-function-go (#26142)

authored and
nodece
committed
a0421bd
[fix][metadata] Fix orphaned UR parent nodes not cleaned up with Oxia metadata backend (#26158)

eugene-polozhenkov
authored and
nodece
committed
2a0f18d
[fix][ci][branch-4.0] Skip testMarkReplicatedDeletesEmptyParentNodes for Etcd

lhotari
authored and
nodece
committed
9dade35
[fix][sec][branch-4.0] Upgrade Netty to 4.1.136.Final (#26170)

lhotari
authored and
nodece
committed
8b075fa
[improve][monitor][branch-4.0] Upgrade OpenTelemetry libraries (#26165)

shibd
authored and
nodece
committed
7838e79
[fix][sec][branch-4.0] Upgrade Jackson version to 2.18.9 (#26187)

shibd
authored and
nodece
committed
fc9df80
[fix][sec][branch-4.0] Upgrade Hadoop to 3.5.0 (#26195)

shibd
authored and
nodece
committed
e23b2a5
[fix][client] Preserve null values in pulsar-admin schema output (#26196)

Technoboy-
authored and
nodece
committed
5481b29
[fix][broker] Fix `getEstimatedSizeSinceMarkDeletePosition` throw `IllegalArgumentException` (#26184)

Technoboy-
authored and
nodece
committed
e629b76
Fix compile issue

Technoboy-
authored and
nodece
committed
eeddaf8
Fix compile issue

Technoboy-
authored and
nodece
committed
c5b405e
[fix][client] Fix lookup request semaphore not release problem (#25038)

congbobo184
authored and
nodece
committed
2b6580f
[improve][ci] Replace trivy-action with sandboxed-trivy-action (#25480)

lhotari
authored and
nodece
committed
7d1ba7f
[fix][ci] Upgrade sandboxed-trivy-action to approved sha (#26169)

lhotari
authored and
nodece
committed
a787392
[fix][client] Sync ackSet in client with broker to stop acked messages reaching the DLQ (#26135)

Shawyeok
authored and
nodece
committed
a6a27e8
[fix][client] Fix UnAckedMessageRedeliveryTracker to skip cancelled timeouts (#26043)

Dream95
authored and
nodece
committed
7ffef17
[fix][broker] Read subscription properties directly from cursor (#26159)
nodece
committed
830db30
[fix][broker] Fix bucket delayed message index metrics reset on scrape (#26171)
nodece
committed
437bb56
[improve][meta] Upgrade Oxia client to 0.8.0 (#25964)

mattisonchao
authored and
nodece
committed
49b7d63
[improve][meta] Upgrade Oxia client to 0.9.4 (#26193)

merlimat
authored and
nodece
committed
cd18660
[fix][client] Fix lookup permit double-release, waiting queue starvation and timeout-response races in ClientCnx (#26143)

geniusjoe
authored and
nodece
committed
821f09c
[improve][broker] Skip system cursor when check inactive cursor. (#26149)

horizonzy
authored and
nodece
committed
33aa639
[fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state (#26179)

void-ptr974
authored and
nodece
committed
2971a10
[fix][meta] Fix NPE in shouldIgnoreEvent when MetadataEvent options is null (#26200)

authored and
nodece
committed
d84e271
[fix][fn] Return inputSpecs consumerProperties in function GET info (#26217)

Dream95
authored and
nodece
committed
6fe3a23
[fix][broker][branch-4.2] Fix admin API HTTP 400 FAIL_ON_TRAILING_TOKENS when a broker interceptor is loaded (#26223)

lhotari
authored and
nodece
committed
f82268a
[fix][ci][branch-4.0] Fix OpenTelemetrySanityTest after Otel library upgrade

lhotari
authored and
nodece
committed
3bbe882
Fix binary license

lhotari
authored and
nodece
committed
c493dff
[fix][misc][branch-4.0] Make log4j pattern compatible with slog which got pulled in by Oxia client upgrade

lhotari
authored and
nodece
committed
bad0e29
[fix][test] Fix flaky test `testCompactionPriority ` (#26198)

Technoboy-
authored and
nodece
committed
37d178b
[improve][misc][branch-4.0] Add CustomLog config for slog

lhotari
authored and
nodece
committed
efe0c12
[improve][broker][branch-4.0] Trace the asynchronous tasks in logs when loading topics (#26163) (#26224)

BewareMyPower
authored and
nodece
committed
8147cd2
[improve][build] Upgrade slog to 0.10.0 (#26226)

lhotari
authored and
nodece
committed
cfaa7fd
[improve][misc] Upgrade to Alpine 3.23 (#25180)

lhotari
authored and
nodece
committed
e8e76e3
[improve][build] Upgrade docker base image Alpine to 3.24 (#26225)

lhotari
authored and
nodece
committed
9eb075f
[fix][broker] Check deliverAt before containsMessage in bucket addMessage (#26230)
nodece
committed
bbafb00
[fix][broker] Trigger max read position callback for messages published during transaction buffer recovery (#26234)

lhotari
authored and
nodece
committed
f205055
[improve][misc] Upgrade Jetty to 12.1.11 (#26233)

lhotari
authored and
nodece
committed
dbd8ca0
[improve][offload] Support credentials from offload policies for S3 and Aliyun OSS drivers (#26232)

authored and
nodece
committed
e962fa3
[fix][meta] Fix RocksdbMetadataStore instanceId not advancing across restarts (#26218)

authored and
nodece
committed
ed2f0b1
[fix][meta] Record get op stats on the correct completion branch in AbstractMetadataStore (#26201)

authored and
nodece
committed
52f6c51
[fix][meta] Complete handleMetadataEvent future exceptionally when the initial get fails (#26199)

authored and
nodece
committed
ba9d4f2
[fix][broker] Prevent stale read completions from stranding Failover subscriptions (#26174)

alexandrebrg
authored and
nodece
committed
80b6f4b
[fix][broker] Fix Key_Shared delivery stall when look-ahead triggers at the end of the topic (#26236)

lhotari
authored and
nodece
committed
67b3fb8
[fix][broker] Prevent stale topic unload cleanup from removing active cache entries (#26145)

void-ptr974
authored and
nodece
committed
320389c
[fix][broker] Prevent completing replicated snapshot before marker publish (#26119)

Denovo1998
authored and
nodece
committed
8f67fc7
[fix][build][branch-4.0] Fix spotbugs failure in OffloadPoliciesImpl

lhotari
authored and
nodece
committed
c27f9bd
[fix][broker] Fix incorrect listener URLs returned by ModularLoadManager lookups (#26245)

void-ptr974
authored and
nodece
committed
2dc3faf
[fix][broker] Fix delayed message index data loss when trimming overlapping bucket snapshots (#26240)

void-ptr974
authored and
nodece
committed
f9a2f1f
[fix][broker] Fix silently dropped acknowledgement failures in PulsarMetadataEventSynchronizer (#26237)

authored and
nodece
committed
be5ddc3
[fix][fn] Forward source message properties in Python runtime (#26191)

authored and
nodece
committed
694a056
[fix][client] Fix unAckedMessageTracker cleanup on multi-topics batch ack (#26001)

Dream95
authored and
nodece
committed
1e80545
[fix][broker] Fix TableViewLoadDataStoreImpl close deadlock that stalls broker shutdown (#26243)

lhotari
authored and
nodece
committed
7cc56bb
[fix][broker] Prevent stale service unit callbacks from dropping active lookup and cleanup jobs (#26146)

void-ptr974
authored and
nodece
committed
65c0dba
[fix][broker] Release entry on GetLastMessageId when parseMessageMetadata throws (#26089)

authored and
nodece
committed
25b604a
[fix][meta][branch-4.0] Tolerate concurrent creation of the underreplication LAYOUT node (#26248)

lhotari
authored and
nodece
committed
c65b789
[fix][sec][branch-4.2] Upgrade Spring to 7.0.8 (#26270)

lhotari
authored and
nodece
committed
e4e2af2
[improve][fn] Standardize log4j2 Root logger configuration to use system property (#26121)

sandeep-mst
authored and
nodece
committed
4fc6fee
[fix][broker] Log exception in PulsarMetadataEventSynchronizer failure path (#26203)

authored and
nodece
committed
7aa567d
[fix][sec] Bump google.golang.org/grpc from 1.79.3 to 1.82.1 in /pulsar-function-go/examples (#26231)

dependabot[bot]
authored and
nodece
committed
1be5f2f
[fix][sec] Upgrade grpc in pulsar-function-go to 1.82.1 to fix GHSA-hrxh-6v49-42gf (#26235)

lhotari
authored and
nodece
committed
6a93647
[fix][sec] Upgrade lz4-java to 1.11.1 to address CVE-2026-59949 (#26250)

lhotari
authored and
nodece
committed
c0c85c4
[fix][client] Avoid exception in ConsumerImpl hasMessageAvailable before first receive (#25857)

authored and
nodece
committed
454fa55
[fix][ml] Tolerate concurrent creation of the managed ledger z-node (#26247)

lhotari
authored and
nodece
committed
e122ab0
[fix][broker] Fix delayed-delivery bucket merge failures when delayedDeliveryMaxNumBuckets is 1-3 (#26242)

void-ptr974
authored and
nodece
committed
44bbc55
[fix][misc] Remove unnecessary " {}" suffix from log lines when there are no context attributes (#26285)

lhotari
authored and
nodece
committed
75ae9b3
[fix][admin] Avoid creating subscriptions when peeking messages if auto-creation is disabled (#26279)

void-ptr974
authored and
nodece
committed
8b5ce63
[fix][txn] Fix X-Pulsar-txn-uncommitted header semantics and add X-Pulsar-txn-consumable for peek messages (#26073)

poorbarcode
authored and
nodece
committed
fab20c4
[fix][sec][branch-4.2] Upgrade Netty to 4.1.137 to address several CVEs and bugs (#26301)

lhotari
authored and
nodece
committed
ad3e222
[improve][misc] Upgrade Jetty to 12.1.12 (#26302)

lhotari
authored and
nodece
committed
654d8d0
[fix][ml] Skip contiguous deleted ranges during reads (#26299)

coderzc
authored and
nodece
committed
4b5704b
[improve][broker] Expose interface for the replicator in ManagedLedger instead of cast the class (#26298)

zymap
authored and
nodece
committed
9175b4e
[Fix][broker]Get a fenced error when loading a topic that does not allowed the cluster to access (#26276)

poorbarcode
authored and
nodece
committed
a2c8d17
[improve][misc] Upgrade Conscrypt to 2.6.1 to add aarch64 native support (#26314)

lhotari
authored and
nodece
committed
0d10a1b
[fix][client] Restore OAuth2 HTTP client after deserialization (#26325)

jiangpengcheng
authored and
nodece
committed
0a64cb7
[improve][misc] Upgrade Conscrypt to 2.6.2 to restore the native library glibc baseline (#26315)

lhotari
authored and
nodece
committed
fa27e06
[improve][misc] Upgrade log4j to 2.26.0 and slf4j to 2.0.18 (#25973)

lhotari
authored and
nodece
committed
c2b7e0b
[fix][sec] Bump log4j2 from 2.26.0 to 2.26.1 (#26329)

authored and
nodece
committed
ae5e1c5
[fix][sec] Upgrade Jackson to 2.18.10 (#26339)

lhotari
authored and
nodece
committed
7cb381e
[fix][broker] Prevent Key_Shared out-of-order replay starvation at the end of topic (#26268)

Denovo1998
authored and
nodece
committed
01edfab
[fix][test] Fix flaky AdminApiTest caused by leaked brokerShutdownTimeoutMs (#26249)

lhotari
authored and
nodece
committed
284dfc6
[fix][offload] Normalize offloader cache directory path (#26372)

coderzc
authored and
nodece
committed
c7c4a74
[fix][client] Apply no-memory-limit producer queue defaults at producer creation (#26342)

lhotari
authored and
nodece
committed
68ddfdd
[fix][cli][branch-4.0] Don't pass unset pulsar-perf pending-message options to the producer (#26371)

lhotari
authored and
nodece
committed
691f812
[fix][sec][branch-4.2] Upgrade BouncyCastle to 1.85 and BouncyCastle FIPS to 2.0.2 to address CVEs (#26370)

lhotari
authored and
nodece
committed
7a4b4d1
[fix][test][branch-4.2] Create the CLI test producer only once CmdProduce asks for it

lhotari
authored and
nodece
committed
3ff5479
[fix][cli] Set --enable-native-access=ALL-UNNAMED for the CLI tools on Java 24+ (#26365)

lhotari
authored and
nodece
committed
55f2190
[fix][test] Fix OneWayReplicatorSchemaValidationEnforcedTest racing the replicator's remote topic creation (#26382)

lhotari
authored and
nodece
committed
db9452e
[fix][client] Divide the across-partitions budget only when it was set explicitly (#26384)

lhotari
authored and
nodece
committed
ebad291
[improve][broker] Change partition metadata not-found log to warn (#26381)

Technoboy-
authored and
nodece
committed
50132fd
[fix][fn] Honour negativeAckRedeliveryDelayMs in the Go function runtime (#26415)

david-streamlio
authored and
nodece
committed
c7c559b
[fix][broker] Do not log an error when the tenant does not exist (#26361)

codelipenghui
authored and
nodece
committed
a86cf32
[fix][test] Fix import order in authorization test

Technoboy-
authored and
nodece
committed
52c901a
[improve][broker] Add pulsar_subscription_storage_backlog_age_seconds metric (#26313)

Technoboy-
authored and
nodece
committed
4f5d2a0
Fix cherry-pick
nodece
committed
43c03dd
[refactor][broker] Decouple delayed delivery trackers from dispatcher (#25384)

Denovo1998
authored and
nodece
committed
8afddf0
[improve][broker] Optimize TripleLongPriorityQueue heap operations (#26010)
nodece
committed
8f1dc74
[improve][broker] Add LongBitmap abstraction and migrate RoaringBitmap usage to LongBitmap (#26117)
nodece
committed
5e8dcf8
[fix][common] Adapt TripleLongPriorityQueueTest to client compiler release level
nodece
committed
1e86cf7
[improve][ml] Replace RangeSetWrapper with PositionRangeSet backed by LongBitmap (#26127)
nodece
committed
889cb3f
Keep managedLedgerPersistIndividualAckAsLongArray default at false
nodece
committed
a3c92ed
[fix][broker] Remove BucketDelayedDeliveryTrackerBenchmark
nodece
committed
33380cc
[improve][broker] Optimize SegmentedLongArray with heap-backed long[][] (#26183)
nodece
committed
d078618
[fix][broker] Remove lock contention in delayed delivery stats read paths (#25990)
nodece
committed
1a26bc2
[improve][broker] Optimize bucket delayed-delivery bitmap point operations (#26205)
nodece
committed
34dc3b4
[fix][broker] Fix bucket delayed delivery counter and dedup consistency (#26251)
nodece
committed
7426970
[improve][broker] Unify dedup index for in-memory and bucket delayed delivery trackers
nodece
committed
95a0edc
[improve][ml] Per-msgLedger individual ack checkpoint persistence
nodece
committed
8b87c1f
Bump version to next snapshot version
nodece
committed
3dae4c5
[fix][test] Fix BooleanSupplier import in PulsarMockBookKeeper
nodece
committed
760ed52

Commits on Aug 31, 2026

[improve][broker] PIP-299-part-2: add config dispatcherPauseOnAckStatePersistentEnabled (#21370)

poorbarcode
authored and
nodece
committed
d333190
[fix][bench] Add package-info for managed-ledger microbench packages
nodece
committed
c70c757
[fix][style] Fix static import order in StandaloneTest
nodece
committed
8a94d48
Update LICENSE.bin.txt lz4-java version to 1.11.1
nodece
committed
b49e45f
[fix][ml] Null-safe OTel stats recording for mocked-ledger unit tests
nodece
committed
72ebc50
[fix][test] Stub hierarchy topic policies in replicator test fixture
nodece
committed
24cb2f5
[fix][broker] Fix replicator getting stuck under rate limiter throttling and honor readBatchSize/maxReadSizeBytes on the default read path (#26005)

authored and
nodece
committed
d8e4ca7
[refactor][broker] Unify limiter clamp semantics in replicator read limits
nodece
committed
57868e0

Uh oh!

Commits

Commits on Aug 28, 2026