All pull requests

Pull requests

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

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

  ·

• MINOR: Updated docs for 4.2.2 release (#23612)

  ci-approved
  #23613·apoorvmittal10 opened Sep 28, 2026Contributor·

  ·

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

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

  ·

• MINOR: Add streams group protocol integration test for warm-up tasks

  streamstests
  #23608·lucasbru opened Sep 28, 2026Member·

  ·
  4

• MINOR: fix record time in test shouldSurviveWithOneTaskAsStandby

  smallstreamsteststriage
  #23606·Russole opened Sep 28, 2026Contributor·

  ·
  2

• MINOR: Close leaked RemoteLogManager instances in RemoteLogManagerTest

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

  ·
  3

• 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-21149: Speed up JoinGracePeriodDurabilityIntegrationTest

  smallstreamsteststriage
  #23600·Russole opened Sep 27, 2026Contributor·

  ·
  4

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

  ·

• KAFKA-15423: var int overflow

  clientsproducersmall
  #23593·git-ai-coder opened Sep 26, 2026·

  ·
  4

• MINOR: Replace Collections factory methods with Java 11+ equivalents in clients consumer, producer and admin

  clientsconsumerproducertriage
  #23592·see-quick opened Sep 26, 2026Collaborator·

  ·

• KAFKA-21167: Filter out members at quota before selecting sticky task candidates.

  ci-approvedgroup-coordinatorsmalltriage
  #23591·chickenchickenlove opened Sep 26, 2026Contributor·

  ·

• KAFKA-21088: Restore PUSH_NEEDED when telemetry payload construction fails

  ci-approvedclientssmalltriage
  #23590·nileshkumar3 opened Sep 26, 2026Contributor·

  ·

• KAFKA-20999: Add rack-aware standby task assignment

  group-coordinatortriage
  #23588·gabriellefu opened Sep 25, 2026Contributor·

  ·

• MINOR: Restore interrupt status in InterruptedException catch blocks

  clientsconnectconsumerkraftmirror-maker-2smallstreamstools
  #23587·TimurRakhmatullin86 opened Sep 25, 2026·

  ·

• MINOR: Update test for review comments

  smallstreamstests
  #23586·bbejeck opened Sep 24, 2026Member·

  ·
  4

• KAFKA-21161: Checkpoint consumed offset over produced offset for source-topic changelog stores

  smallstreams
  #23585·bbejeck opened Sep 24, 2026Member·

  ·
  3

• KAFKA-21159: Clear next offsets to consume on task close to avoid stale commit after revive

  smallstreams
  #23584·bbejeck opened Sep 24, 2026Member·

  ·
  3

• KAFKA-21150: Refactor AbstractKafkaConfig#processRoles

  coresmall
  #23581·majialoong opened Sep 24, 2026Collaborator·

  ·
  5

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

  group-coordinator
  #23575·squah-confluent opened Sep 24, 2026Contributor·

  ·
  8

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

  group-coordinatorperformance
  #23574·squah-confluent opened Sep 24, 2026Contributor·

  ·
  7

• KAFKA-21152: LogCompactionTester should read until the end offsets instead of stopping at an empty poll

  tools
  #23572·unknowntpo opened Sep 24, 2026Contributor·

  ·