All pull requests

Pull requests

• [improve][pip] PIP-496: Pulsar Functions and IO support for the V5 client and scalable topics

  PIP
  #26698·lhotari opened Sep 23, 2026Member·

  ·

• [feat][fn] PIP-496: Support the V5 client and topic:// topics in Pulsar Functions and IO

  #26697·lhotari opened Sep 23, 2026Member·

  ·

• [improve][pip] PIP-246: Improved PROTOBUF_NATIVE schema compatibility checks without using avro-protobuf

  PIP
  #26695·Denovo1998 opened Sep 23, 2026Contributor·

  ·

• [improve][pip] PIP-495: Scalable Topic Geo-Replication

  PIP
  #26692·merlimat opened Sep 22, 2026Contributor·

  ·

• [fix][broker] Do not start classic geo-replicators on scalable-topic segment topics

  #26691·merlimat opened Sep 22, 2026Contributor·

  ·

• [fix][client]in chunk message consumer, pendingChunkedMessageCount is not synced with count of entries present in chunkedMessagesMap

  #26689·programmerahul opened Sep 22, 2026Contributor·

  ·
  1

  3

• [fix][test] Wait for the ack to be persisted before rewinding in V5StreamConsumerAckWatermarkTest

  #26684·namest504 opened Sep 22, 2026Contributor·

  ·
  1

• [fix][ml] Fail queued adds when a managed ledger is terminated during a ledger rollover

  #26680·merlimat opened Sep 21, 2026Contributor·

  ·
  3

• [fix][meta] Fix underreplication locks left behind when closing by handling each deletion independently

  #26674·void-ptr974 opened Sep 21, 2026Contributor·

  ·

• [fix][client] Schedule TableView tail-read retries instead of sleeping on the callback thread

  #26672·namest504 opened Sep 21, 2026Contributor·

  ·
  1

• [fix][meta] Return LedgerExistException for duplicate ledger creation

  triage/lhotari/important
  #26669·void-ptr974 opened Sep 21, 2026Contributor·

  ·

  · 5.0.0

• [improve][broker] trace topic loading latency and timeout states

  ready-to-testrelease/4.2.5
  #26666·poorbarcode opened Sep 20, 2026Contributor·

  ·

  · 5.0.0
  

• [fix][broker] Prevent stale messages from surviving compaction retries

  #26664·Denovo1998 opened Sep 20, 2026Contributor·

  ·

• [fix][broker] Fix unacked accounting races during consumer removal

  #26663·Denovo1998 opened Sep 20, 2026Contributor·

  ·

• [fix][misc] Preserve the sign of negative fractions in text output

  #26662·hiSandog opened Sep 20, 2026Contributor·

  ·

• [fix][Client] permit leak in chunked message discard path

  #26661·programmerahul opened Sep 19, 2026Contributor·

  ·
  1

  7

• [fix] [client] chunked message uuid-queue never removes entries on successful processing

  #26658·programmerahul opened Sep 19, 2026Contributor·

  ·
  1

  3

• [fix][broker] Prevent stale consumer removal from removing replacements

  #26652·Denovo1998 opened Sep 19, 2026Contributor·

  ·
  3

• [fix][fn] Ack late tuples in window functions under ATLEAST_ONCE

  #26651·Dream95 opened Sep 19, 2026Contributor·

  ·
  1

• [fix][client] Prevent duplicate cleanup and leaks on producer send failures

  #26641·Denovo1998 opened Sep 18, 2026Contributor·

  ·
  9

• [fix][client] Recover listener delivery after executor rejection

  #26640·Denovo1998 opened Sep 18, 2026Contributor·

  ·

• [fix][broker] Retry conflicting system bundle ownership cleanup

  #26634·Denovo1998 opened Sep 17, 2026Contributor·

  ·

• [fix][broker] Avoid misleading ownership lock expiry logs during shutdown

  #26633·Denovo1998 opened Sep 17, 2026Contributor·

  ·
  3

• [improve][broker] Benchmark real batch-index lookup and dispatch paths

  #26632·Denovo1998 opened Sep 17, 2026Contributor·

  ·

• [fix][broker] Fail compacted reads when the compacted ledger is missing

  #26631·Denovo1998 opened Sep 17, 2026Contributor·

  ·