Pull requests

• [fix][meta] Fix leader election close deleting a leader node owned by another session

  #26828·Dream95 opened Oct 6, 2026Contributor·1 of 11 tasks·

  ·

• [improve][broker] Default numIOThreads to half the available processors, at least 8

  #26825·lhotari opened Oct 4, 2026Member·1 of 11 tasks·

  ·
  1

• [feat][monitor] PIP-320: Add OpenTelemetry metrics for the Function Worker

  #26823·Dream95 opened Oct 3, 2026Contributor·1 of 10 tasks·

  ·
  1

• [improve][broker] Record the deduplication's persisted sequence IDs in place

  #26822·lhotari opened Oct 3, 2026Member·11 tasks·

  ·
  2

• [fix][client] Keep per-key order of V5 async sends across scalable topic layout changes

  #26820·lhotari opened Oct 2, 2026Member·1 of 11 tasks·

  ·

• [fix][meta] Fix lost ledger metadata updates during concurrent listener registration and removal

  #26819·void-ptr974 opened Oct 2, 2026Contributor·1 of 11 tasks·

  ·

• [fix][schema] Fix BookKeeper read handle leaks on schema read failures

  #26818·void-ptr974 opened Oct 2, 2026Contributor·11 tasks·

  ·

• [fix][ml] Fix cached read handle leaks when closing read-only managed ledgers

  #26816·void-ptr974 opened Oct 2, 2026Contributor·11 tasks·

  ·

• [fix][ml] Fix metadata listener leaks caused by unclosed temporary read handles

  #26817·void-ptr974 opened Oct 2, 2026Contributor·11 tasks·

  ·

• [fix][client] Fix ZeroQueueConsumer stuck on pending receiveAsync after reconnection

  #26814·subodhwandile opened Oct 2, 2026·2 tasks done·

  ·
  1

  3

• [fix][proxy] Fix direct memory leaks from dropped reference-counted messages

  #26811·Radiancebobo opened Oct 1, 2026Contributor·11 tasks·

  ·
  2

• [improve][testing] Add client/admin builders and temporary directory support for testing standalone service

  #26807·hohoho1886 opened Oct 1, 2026·11 tasks·

  ·
  1

• [fix][test] Fix flaky ScalableTopicControllerAutoScaleTest.testRebucketCooldownSurvivesLeaderFailover

  #26806·lhotari opened Oct 1, 2026Member·11 tasks·

  ·
  1

• [improve][broker] log incompatible schema failures at warn level, rather than logging at error level

  #26804·poorbarcode opened Oct 1, 2026Contributor·10 tasks·

  ·

  · 5.0.0
  1

• [fix][broker] Prevent incorrect isolation fallback during cluster updates

  #26798·Denovo1998 opened Oct 1, 2026Contributor·2 of 11 tasks·

  ·
  1

• [fix][broker] Fix Shared and Key_Shared consumer stalls during FLOW and unblock races

  #26797·void-ptr974 opened Oct 1, 2026Contributor·1 of 10 tasks·

  ·
  10

• [fix][meta] Preserve ownership during underreplication lock cleanup

  #26794·Denovo1998 opened Oct 1, 2026Contributor·2 of 11 tasks·

  ·

• [fix][managed-ledger] Persist partial batch ACKs on flush

  #26765·Asthenia0412 opened Sep 29, 2026Contributor·

  ·
  1

  1

• [fix][ml] Complete the original future after ledger deletion retries

  #26742·zhanghaou opened Sep 29, 2026Contributor·1 of 11 tasks·

  ·

• [fix][compaction] Size rebatch buffers from uncompressed batches

  #26732·Asthenia0412 opened Sep 28, 2026Contributor·

  ·
  1

• [feat][txn] Add TxnID and TransactionCoordinatorClient support to TransactionV5

  #26731·TomaszGaweda opened Sep 28, 2026Contributor·1 of 11 tasks·

  ·
  3

• [fix][broker] evict timed-out topic loads

  #26729·Asthenia0412 opened Sep 28, 2026Contributor·

  ·
  1

  4

• [fix][functions] Forward source message properties in Go functions

  #26728·Asthenia0412 opened Sep 28, 2026Contributor·

  ·
  1

• [fix][client] Return flow-control permit when client seek by messageID

  #26726·programmerahul opened Sep 27, 2026Contributor·1 of 11 tasks·

  ·
  1

  5

• [fix][schema] Fix Protobuf native descriptor deserialization

  #26725·Denovo1998 opened Sep 27, 2026Contributor·2 of 11 tasks·

  ·