All pull requests

Pull requests

• [improve][test] Reduce TransactionConsumeTest wall time from 230s to 122s

  #27219·void-ptr974 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][client] Return only readable bytes from heap messages

  #27217·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][broker] Balance same-name failover consumers across partitions

  #27216·Denovo1998 opened Oct 29, 2026Contributor·4 of 11 tasks·

  ·

• [fix][ml] Fix managed ledger factory shutdown races and timeouts

  #27215·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][broker] Prevent mixed-durability subscription creation races

  #27214·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][broker] Prevent fixed delay detection from blocking messages

  #27213·Denovo1998 opened Oct 29, 2026Contributor·3 of 11 tasks·

  ·

• [fix][ml] Close abandoned managed ledger initialization resources

  #27212·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][client] Prevent premature producer readiness on reconnect

  #27211·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][client] Preserve batch boundaries and recover after failures

  #27210·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][client] Prevent transaction callbacks from blocking client shutdown

  #27209·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][broker] Prevent payload leaks when message serialization fails

  #27208·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][txn] Release late entries after snapshot recovery stops waiting

  #27207·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][broker] Preserve commands across broker interceptors

  #27206·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][ml] Preserve cursor position updates during activation

  #27205·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][meta] Recover bookie watcher notifications after failed reads

  #27204·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][client] Resume sending after messages awaiting schema time out

  #27203·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][broker] Skip bundle queries for cancelled ALL topic listings

  #27202·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][meta] Release closed caches and preserve migration listeners

  #27201·Denovo1998 opened Oct 29, 2026Contributor·4 of 11 tasks·

  ·

• [fix][client] Send pending acks before listener and resume permits on reconnect

  #27200·Denovo1998 opened Oct 29, 2026Contributor·2 of 11 tasks·

  ·

• [fix][broker] Avoid waiting for bucket recovery when clearing backlog

  #27199·Denovo1998 opened Oct 29, 2026Contributor·3 of 11 tasks·

  ·

• [fix][txn] Balance pending writes when publish callbacks throw

  #27198·Denovo1998 opened Oct 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][broker] Prevent duplicate delivery from queued dispatches after reconnect

  #27197·Denovo1998 opened Oct 29, 2026Contributor·3 of 11 tasks·

  ·

• [improve][ci] Reduce disk usage and extend Broker Group 1 timeout in Pulsar CI

  #27196·lhotari opened Oct 29, 2026Member·11 tasks·

  ·

• [fix][ci] Upgrade gradle/actions to 6.4.1 (GHSA-chpw-2mqm-95cc) and develocity-actions to 2.5

  #27179·lhotari opened Oct 29, 2026Member·11 tasks·

  ·

• [improve][admin] PIP-500: Get all topic-level policies with a single admin call

  #27175·hangc0276 opened Oct 29, 2026Contributor·11 tasks·

  ·
  2