All pull requests

Pull requests

• MINOR: Replace Collections factory methods with Java 9+ equivalents in server tests

  coresmallteststriage
  #23652·sunm2n opened Oct 1, 2026Contributor·

  ·

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

  clientsconsumercoreproducertriage
  #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

• MINOR: Accumulate renew ack checks from all nodes

  clientsconsumerKIP-932small
  #23649·AndrewJSchofield opened Sep 30, 2026Member·

  ·
  2

• 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-approvedcoretriage
  #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·

  ·
  6

• MINOR: Clarify remote log event timestamp semantics

  ci-approvedsmallstoragetiered-storage
  #23626·liuliuOD opened Sep 29, 2026Contributor·

  ·
  4

• MINOR: Add PartitionsWithLateTransactionsCount description to monitoring.md

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

  ·

• KAFKA-20292 [11/N]: Split streams TargetAssignmentBuilder

  group-coordinator
  #23624·squah-confluent opened Sep 29, 2026Contributor·

  ·
  18

• KAFKA-20292 [10/N]: Split consumer and share TargetAssignmentBuilder

  group-coordinatorperformance
  #23623·squah-confluent opened Sep 29, 2026Contributor·

  ·
  4

• MINOR: Add streams group integration tests for the warm-up task lifecycle

  streamstests
  #23620·lucasbru opened Sep 29, 2026Member·

  ·
  1

• KAFKA-21026: Add JMH benchmark for the streams assignment refiner

  performancetriage
  #23616·suzhiking opened Sep 29, 2026Contributor·

  ·

• KAFKA-21172: Set changelog retention for all smoke-test clients in system tests

  smallstreamstriage
  #23615·unknowntpo opened Sep 29, 2026Contributor·

  ·

• KAFKA-21142: fix partition creation when handling snapshot delta during migration

  #23610·gaurav-narula opened Sep 28, 2026Contributor·

  ·

• MINOR: Close leaked RemoteLogManager instances in RemoteLogManagerTest

  smallstorageteststiered-storage
  #23604·unknowntpo opened Sep 28, 2026Contributor·

  ·
  4

• KAFKA-21148: Speed up JoinStoreIntegrationTest

  ci-approvedsmallstreamsteststriage
  #23602·dino2895 opened Sep 28, 2026Contributor·

  ·
  1

• KAFKA-19034: Complete RemoteTopicCrudTest migration

  ci-approvedcorestorageteststriage
  #23601·hjtiun852 opened Sep 28, 2026Contributor·

  ·
  1

• KAFKA-21170: Validate Streams task assignor output before accepting target assignments.

  group-coordinatortriage
  #23597·chickenchickenlove opened Sep 27, 2026Contributor·

  ·

• KAFKA-21158: Document/warn about future timestamps allowed by message.timestamp.after.max.ms

  ci-approvedclientscorestorage
  #23596·muralibasani opened Sep 27, 2026Contributor·

  ·
  2

• KAFKA-21169: Treat empty and absent subtopology task sets as equivalent.

  group-coordinatortriage
  #23595·chickenchickenlove opened Sep 27, 2026Contributor·

  ·