All pull requests

Pull requests

• KAFKA-17965 [2/N]: Record local time on coordinator threads

  coregroup-coordinatorKIP-932performancetriage
  #24238·squah-confluent opened Nov 15, 2026Contributor·

  ·
  1

• KAFKA-21444: Document or clarify acks=1 durability during planned leader transitions (kafka-site)

  docssmalltriage
  #24237·lucliu1108 opened Nov 15, 2026Collaborator·

  ·

• KAFKA-21357: Fix "null keyChangingChild node" with nested merges

  streamstriage
  #24236·siddharthaDevineni opened Nov 14, 2026Contributor·

  ·

• KAFKA-21516: Preserve share group state on initialization retries

  KIP-932triage
  #24235·Radiancebobo opened Nov 14, 2026·

  ·

• KAFKA-20883,20888: Expose instance id and rack id for streams describe command

  ci-approvedtoolstriage
  #24234·chickenchickenlove opened Nov 14, 2026Collaborator·

  ·

• MINOR: Fix config names that do not exist in docs

  clientssmallstreamstriage
  #24233·rawsun007 opened Nov 14, 2026·

  ·

• KAFKA-17965 [1/N]: Refactor request local time tracking

  coreperformancetriage
  #24232·squah-confluent opened Nov 14, 2026Contributor·

  ·

• MINOR: Remove GroupConfigManager#close

  ci-approvedcoregroup-coordinatorsmalltriage
  #24231·chungyichi opened Nov 14, 2026Contributor·

  ·

• KAFKA-21511: Upgrade dependencies with CVE fixes for 3.9

  #24230·harmadasg opened Nov 14, 2026Contributor·

  ·
  1

• KAFKA-21509: Backort bound size fields in Streams and ListDeserializer deserializers

  #24229·harmadasg opened Nov 14, 2026Contributor·

  ·
  1

• KAFKA-21507: Fix incorrect TaskMetadata.endOffset

  smallstreams
  #24228·mjsax opened Nov 14, 2026Member·

  ·

• MINOR: fix incorrect usage of "end offset" inside Kafka Streams

  streams
  #24227·mjsax opened Nov 13, 2026Member·

  ·

• KAFKA-21478: Add client-side handling for unexpected HB processing failures

  clientsconsumer
  #24226·lianetm opened Nov 13, 2026Member·

  ·

• KAFKA-21503: Add MirrorPartition record type

  ci-approvedcluster-mirroringcoretriage
  #24223·fvaleri opened Nov 13, 2026Contributor·

  ·
  1

• MINOR: Avoid deprecated G1 heap occupancy option on Java 27

  smalltriage
  #24222·danez opened Nov 13, 2026Contributor·

  ·

• KAFKA-20131; KAFKA-20449: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls

  #24221·lianetm opened Nov 13, 2026Member·

  ·
  1

• KAFKA-21214: Avoid a cohort scan per extra partition in AssignRemainingExtraPartitions (follow-up)

  group-coordinatoruniform2
  #24220·dajac opened Nov 13, 2026Member·

  ·

• KAFKA-20731: transitToUpdateStandby is called without checking ACTIVE_RESTORING (#22864)

  #24219·lucasbru opened Nov 13, 2026Member·

  ·

• KAFKA-20731: transitToUpdateStandby is called without checking ACTIVE_RESTORING (#22864)

  #24218·lucasbru opened Nov 13, 2026Member·

  ·

• KAFKA-20731: transitToUpdateStandby is called without checking ACTIVE_RESTORING (#22864)

  #24217·lucasbru opened Nov 13, 2026Member·

  ·

• KAFKA-21486: Don't fail streams heartbeat with user endpoint when topology is not ready

  group-coordinator
  #24216·lucasbru opened Nov 13, 2026Member·

  ·
  7

  

• MINOR: Use a separate error for unknown users in ScramSaslServer

  clientssmalltriage
  #24215·aashish-confluent opened Nov 13, 2026Contributor·

  ·

• MINOR: Improve validation in OAuthBearerValidatorCallbackHandler

  clientssmalltriage
  #24214·aashish-confluent opened Nov 13, 2026Contributor·

  ·

• KAFKA-21460: Preserve existing Root settings when overriding log4j2 root log level in Docker

  ci-approvedcoretriage
  #24213·Icewind52 opened Nov 13, 2026·

  ·
  1

• KAFKA-21491: Update brokersToElrs when replaying ClearElrRecord

  kraftsmall
  #24211·adeetya-u opened Nov 13, 2026·

  ·
  1