All pull requests

Pull requests

• 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

  clientscorestoragetriage
  #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-21133: Speed up FineGrainedAutoResetIntegrationTest

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

  ·

• KAFKA-15423: var int overflow

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

  ·
  2

• 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

  clientssmalltriage
  #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·

  ·
  1

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

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

  ·
  1

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

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

  ·
  1

• KAFKA-21154: Worker#startTask should close the instances when encountering error

  connect
  #23583·lucliu1108 opened Sep 24, 2026Collaborator·

  ·
  6

• KAFKA-21150: Refactor AbstractKafkaConfig#processRoles

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

  ·
  5

• KAFKA-21157: Bump Jackson version to 2.22.3

  buildci-approveddependenciessmall
  #23580·harmadasg opened Sep 24, 2026Contributor·

  ·
  1

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

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

  ·
  6

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

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

  ·
  5

• KAFKA-21041: Fix ClientMetricsConfigs rejecting match patterns whose regex contains '='

  coresmall
  #23573·DeepikaMamidipelly009 opened Sep 24, 2026·

  ·

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

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

  ·

• MINOR: Fix FindCoordinator v4+ routing in KafkaProtocolFaultProxy

  clientstests
  #23571·bbejeck opened Sep 23, 2026Member·

  ·
  2

• KAFKA-17249: Do not truncate the local log before the remote log aux state is fetched

  ci-approvedcorestoragetiered-storage
  #23569·dybyte opened Sep 23, 2026Contributor·

  ·
  2

• KAFKA-21135: Add unit tests for StandardAuthorizer rate metrics

  kraftsmalltests
  #23568·majialoong opened Sep 23, 2026Collaborator·

  ·
  1

• KAFKA-15821: Reset active topics when deleting standalone connectors

  connectsmall
  #23567·noojung opened Sep 23, 2026·

  ·
  9

• KAFKA-21146 Fix BrokerTopicStats leaks in tests

  ci-approvedcoreKIP-932storageteststoolstriage
  #23561·andyhuangdev opened Sep 23, 2026Contributor·

  ·
  1