All pull requests

Pull requests

• 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

• KAFKA-21490: Release cached share resources on broker shutdown

  ci-approvedcoreKIP-932
  #24210·cxm940188 opened Nov 13, 2026·

  ·
  1

• KAFKA-21252: Use partition 0's replication factor when adding partitions

  clientskraftsmalltriage
  #24209·unknowntpo opened Nov 13, 2026Contributor·

  ·

• KAFKA-20925: Use request header v3 in ApiVersions, Envelope, Fetch and Produce

  ci-approvedclientscoreKIP-932
  #24208·alanlau28 opened Nov 12, 2026Contributor·

  ·
  2

• MINOR: Fix misleading ConfigException for invalid Cast spec

  connectsmalltriage
  #24207·amalsaidov opened Nov 12, 2026·

  ·