All pull requests

Pull requests

• [improve][broker] Cache the topics patterns of topic list requests

  #27364·codelipenghui opened Nov 5, 2026Contributor·11 tasks·

  ·

• [improve][broker] Don't compile the topics pattern of watch requests that reconcile an existing watcher

  #27363·codelipenghui opened Nov 5, 2026Contributor·11 tasks·

  ·

• [improve][broker] Check offload storage asynchronously at startup

  #27361·AuroraTwinkle opened Nov 5, 2026Contributor·4 of 11 tasks·

  ·
  1

  2

• [improve][common] Port the Caffeine cache metrics to the Prometheus Java client 1.x

  skip-cherry-pick
  #27360·namest504 opened Nov 5, 2026Contributor·4 of 15 tasks·

  ·

• [fix][broker] Match Basic auth prefix in any locale

  #27358·sharanggupta opened Nov 4, 2026Contributor·2 of 15 tasks·

  ·
  3

• [fix][client] Throw IOException for bad V5 bytes

  #27357·sharanggupta opened Nov 4, 2026Contributor·11 tasks·

  ·
  2

• [fix][client] Route legacy segments like v4

  #27356·sharanggupta opened Nov 4, 2026Contributor·11 tasks·

  ·

• [fix][txn] Give the transaction buffer request credit back before completing the request

  area/transaction
  #27355·merlimat opened Nov 4, 2026Contributor·11 tasks·

  ·

• [fix][broker] Correct the error message for missing partitions

  #27351·AuroraTwinkle opened Nov 4, 2026Contributor·1 of 11 tasks·

  ·
  1

• [improve][monitor] Expose the Prometheus Java client 1.x default registry in broker and proxy system metrics

  skip-cherry-pick
  #27350·namest504 opened Nov 4, 2026Contributor·3 of 11 tasks·

  ·
  3

• [fix][broker] Don't drop the preallocation of a bundle that its broker is still acquiring

  area/broker
  #27340·merlimat opened Nov 3, 2026Contributor·11 tasks·

  ·
  6

• [fix][client] Don't block IO thread on lazy start

  #27332·sharanggupta opened Nov 3, 2026Contributor·11 tasks·

  ·
  1

  12

• [fix][client] Fail a retried subscribe or producer creation at its timeout, not up to a max backoff interval after it

  area/client
  #27330·merlimat opened Nov 3, 2026Contributor·11 tasks·

  ·
  11

• [fix][admin] Correct auth policy field names in OpenAPI

  #27327·AuroraTwinkle opened Nov 3, 2026Contributor·1 of 11 tasks·

  ·
  1

• [fix][broker] Restore unacked count after aborted transactional ACKs

  #27325·Lcos-000 opened Nov 3, 2026·11 tasks·

  ·
  1

• [improve][monitor] Port the ZooKeeper Prometheus stats provider to the Prometheus Java client 1.x

  skip-cherry-pick
  #27324·RiemannChow opened Nov 3, 2026·3 of 11 tasks·

  ·
  5

• [improve][broker] Add metrics for producer creation failures

  #27323·AuroraTwinkle opened Nov 3, 2026Contributor·1 of 11 tasks·

  ·
  1

• [fix][client] Keep the messages and permits of partitions that a multi-topics seek skips

  #27300·merlimat opened Nov 2, 2026Contributor·

  ·
  1

  2

• [fix][broker] Skip entries with invalid num_messages_in_batch metadata in dispatcher

  #27293·lhotari opened Nov 2, 2026Member·11 tasks·

  ·

• [feat][fn] PIP-501: Support scheduled delivery for Java records

  #27288·freeznet opened Nov 2, 2026Contributor·

  ·

• [improve][pip] PIP-501: Scheduled delivery metadata for Java Functions and IO records

  PIP
  #27287·freeznet opened Nov 2, 2026Contributor·

  ·
  1

  

• [fix][broker] Recover interrupted scalable topic layout transitions

  ready-to-testrelease/5.0.2type/bug
  #27286·codelipenghui opened Nov 1, 2026Contributor·4 of 11 tasks·

  ·

  · 5.1.0
  4

  

• [fix][broker] Revalidate ownership before loading fenced topics

  ready-to-testrelease/5.0.2type/bug
  #27285·codelipenghui opened Nov 1, 2026Contributor·2 of 11 tasks·

  ·

  · 5.1.0
  5

  

• [fix][client] Enforce scalable producer send timeouts while waiting for segments

  ready-to-testrelease/5.0.2type/bug
  #27283·codelipenghui opened Nov 1, 2026Contributor·1 of 11 tasks·

  ·

  · 5.1.0
  2

  

• [fix][ml] Wait for durable completion of duplicate ledger termination

  ready-to-testrelease/5.0.2type/bug
  #27282·codelipenghui opened Nov 1, 2026Contributor·1 of 11 tasks·

  ·

  · 5.1.0
  2