All pull requests

Pull requests

• MINOR: Add broker integration tests for topology-description plugin failure surfacing

  coretests
  #23670·lucasbru opened Oct 1, 2026Member·

  ·
  4

• [MINOR] Add policy validation to CreatePartitions

  #23669·ahuang98 opened Oct 1, 2026Contributor·

  ·

• [MINOR] Add policy validation to CreatePartitions

  krafttriage
  #23668·ahuang98 opened Oct 1, 2026Contributor·

  ·

• KAFKA-20292 [13/N]: Add streams GroupSpecBuilder.withAssignorOffload()

  group-coordinatorsmalltriage
  #23667·squah-confluent opened Oct 1, 2026Contributor·

  ·
  1

• KAFKA-20292 [12/N]: Add consumer and share GroupSpecBuilder.withAssignorOffload()

  group-coordinatortriage
  #23666·squah-confluent opened Oct 1, 2026Contributor·

  ·

• KAFKA-21160 improve RequestHeader parsing on the broker

  clientscoretriage
  #23665·m1a2st opened Oct 1, 2026Contributor·

  ·

• MINOR: Resilience improvements on leadership change

  clientsconsumersmall
  #23664·AndrewJSchofield opened Oct 1, 2026Member·

  ·

• KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches

  clientsproducerstoragetriage
  #23663·frankvicky opened Oct 1, 2026Contributor·

  ·
  6

• KAFKA-15853: [4/N] Move DynamicLogConfig and log config accessors to Java

  coretriage
  #23662·clolov opened Oct 1, 2026Contributor·

  ·

• KAFKA-15853: [3/N] Move DynamicReplicationConfig to Java

  coresmalltriage
  #23661·clolov opened Oct 1, 2026Contributor·

  ·

• KAFKA-21183: Remove MD5 and SHA-1 checksum files from our release process

  ci-approvedsmalltriage
  #23660·jim0987795064 opened Oct 1, 2026Contributor·

  ·
  2

• KAFKA-21197: Preserve original record headers in share group DLQ records.

  ci-approvedclientscoreKIP-932triage
  #23659·smjn opened Oct 1, 2026Collaborator·

  ·

• KAFKA-21193: Speed up SuppressionIntegrationTest

  ci-approvedsmallstreamsteststriage
  #23655·sunm2n opened Oct 1, 2026Contributor·

  ·

• KAFKA-21183: Remove MD5 and SHA-1 checksum files from release process

  ci-approvedsmalltriage
  #23654·ykisana opened Oct 1, 2026·

  ·

• KAFKA-18566: Document invalid UTF-8 offset metadata

  clientsconsumersmalltriage
  #23653·JaneNSea opened Oct 1, 2026·

  ·

• KAFKA-20924: Use Request Header v3 for GetTelemetrySubscriptions and PushTelemetry v1

  ci-approvedclientsconsumercoreproducertriage
  #23651·alanlau28 opened Sep 30, 2026Contributor·

  ·

• KAFKA-21190: Skip remote aux state rebuild when the fetch start offset equals the log start offset

  coresmalltriage
  #23650·jax-shopify opened Sep 30, 2026·

  ·
  1

• KAFKA-21062: Handle BADVERSION on /migration writes

  #23639·mwesterby opened Sep 30, 2026Contributor·

  ·

• KAFKA-21182: includes pending revocation tasks to StreamsGroupDescribe API.

  coregroup-coordinatortriage
  #23638·chickenchickenlove opened Sep 30, 2026Contributor·

  ·

• KAFKA-21185: bump lz4 to 1.12.0

  builddependenciessmalltriage
  #23637·harmadasg opened Sep 30, 2026Contributor·

  ·

• MINOR: Replace try/fail/catch with assertThrows in remaining Streams tests

  ci-approvedstreamsteststriage
  #23636·sunm2n opened Sep 30, 2026Contributor·

  ·

• KAFKA-20812 Move additional KRaftClusterTest tests to KafkaClusterTestKitTest

  buildci-approvedcore
  #23635·dino2895 opened Sep 30, 2026Contributor·

  ·
  1

• MINOR: Fix service principal name logged for native GSSAPI private credentials

  clientssmalltriage
  #23633·Sean-Walker0 opened Sep 30, 2026Contributor·

  ·

• KAFKA-21181: Return NOT_COORDINATOR from a stale transaction coordinator cache

  ci-approvedcoretransactions
  #23630·rreddy-22 opened Sep 29, 2026Contributor·

  ·
  7

• MINOR: Add PartitionsWithLateTransactionsCount description to monitoring.md

  ci-approveddocssmalltriage
  #23625·kouki-tw opened Sep 29, 2026·

  ·