All pull requests

Pull requests

• KAFKA-21234: Fix bug in KRaft where the metadata layer can receive records past the high watermark

  clientskrafttriage
  #23737·kevin-wu24 opened Oct 6, 2026Contributor·

  ·

• KAFKA-21214: [6/N] Add the partition placement of the uniform2 assignor

  group-coordinatoruniform2
  #23736·dajac opened Oct 6, 2026Member·

  ·

• KAFKA-21214: [5/N] Add the balance step of the uniform2 assignor

  group-coordinatoruniform2
  #23735·dajac opened Oct 6, 2026Member·

  ·

• KAFKA-21214: [4/N] Add extra partition moves to the uniform2 assignor

  group-coordinatoruniform2
  #23734·dajac opened Oct 6, 2026Member·

  ·

• KAFKA-21214: [3/N] Add the shares and hand out of the uniform2 assignor

  group-coordinatoruniform2
  #23733·dajac opened Oct 6, 2026Member·

  ·

• KAFKA-21214: [2/N] Add the group model of the uniform2 assignor

  group-coordinatoruniform2
  #23732·dajac opened Oct 6, 2026Member·

  ·

• MINOR: Fix consumer group offset handler chain indentation

  clientssmalltriage
  #23731·ishu7w opened Oct 6, 2026·

  ·

• KAFKA-21232 Apache dependencies version upgrades: Ldap Api and Directory server

  buildcoresmalltriage
  #23730·dejan2609 opened Oct 6, 2026Contributor·

  ·
  6

• KAFKA-21222: Add broker-level configs for Cluster Mirroring

  buildclientscoreperformancestoragetriage
  #23729·fvaleri opened Oct 6, 2026Contributor·

  ·

• KAFKA-21230: Pause processing on uncommitted bytes

  streamstriage
  #23728·nicktelford opened Oct 6, 2026Contributor·

  ·

• MINOR: Clean up Streams header adapter tests after KAFKA-20224

  ci-approvedstreamsteststriage
  #23727·aliehsaeedii opened Oct 6, 2026Contributor·

  ·
  1

• KAFKA-14019: Skip LeaveGroup when removing all members from an empty consumer group

  clientssmalltriage
  #23726·ojasvajain opened Oct 6, 2026·

  ·

• KAFKA-21229: Preserve request offsets in async commit failure callbacks

  ci-approvedclientsconsumersmall
  #23725·chickenchickenlove opened Oct 6, 2026Contributor·

  ·

• KAFKA-21214: [8/8] Add a fuzzer for the uniform2 assignor

  group-coordinatorperformanceuniform2
  #23724·dajac opened Oct 6, 2026Member·

  ·
  1

• KAFKA-21214: [7/N] Add the uniform2 consumer group assignor

  group-coordinatorperformanceuniform2
  #23723·dajac opened Oct 6, 2026Member·

  ·
  1

• KAFKA-21227: Speed up ColdStartStickinessIntegrationTest

  ci-approvedsmallstreamsteststriage
  #23720·sunm2n opened Oct 6, 2026Contributor·

  ·
  2

• KAFKA-21210 Complete rebalance listener integration test coverage

  ci-approvedclientsteststriage
  #23719·andyhuangdev opened Oct 6, 2026Contributor·

  ·

• MINOR: Add tests that tagged fields are written in ascending tag order

  ci-approvedclientssmalltests
  #23717·gabriellefu opened Oct 5, 2026Contributor·

  ·
  1

• KAFKA-14333: Document PolicyViolationException in Admin#deleteRecords javadoc

  clientssmalltriage
  #23716·rishi-rana opened Oct 5, 2026Contributor·1 task done·

  ·

• MINOR: Propagate ClusterInstance#deleteTopic errors and use it in more tests

  clientsteststoolstriage
  #23715·lytt925 opened Oct 5, 2026Contributor·

  ·

• KAFKA-21220: Fix REMAIN_IN_GROUP close after poll timeout for Consumer Group.

  ci-approvedclientsconsumer
  #23714·chickenchickenlove opened Oct 5, 2026Contributor·

  ·
  3

• MINOR: Clarify duration-based offset reset guidance for partition expansion

  ci-approvedclientsconsumersmall
  #23713·liuliuOD opened Oct 5, 2026Contributor·

  ·
  2

• KAFKA-21219: Fix Streams group close stall with REMAIN_IN_GROUP after poll timeout

  ci-approvedclientsconsumer
  #23712·chickenchickenlove opened Oct 5, 2026Contributor·

  ·
  4

  

• Publish Develocity Build Scans for the Docker images

  builddockersmalltriage
  #23711·donat opened Oct 5, 2026·

  ·
  2

• KAFKA-21217: Skip client-side assignment tag validation for the Streams protocol

  smallstreamstriage
  #23709·chickenchickenlove opened Oct 5, 2026Contributor·

  ·