All pull requests

Pull requests

• KAFKA-20416: Clear consumed offsets on task close

  streams
  #23570·bbejeck opened Sep 23, 2026Member·

  ·
  1

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

  coretriage
  #23569·dybyte opened Sep 23, 2026Contributor·

  ·

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

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

  ·
  1

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

  connectsmalltriage
  #23567·noojung opened Sep 23, 2026·

  ·
  1

• KAFKA-21151: Extract streams group topology description orchestration into a shared runtime abstraction

  group-coordinatortriage
  #23566·lucliu1108 opened Sep 23, 2026Collaborator·

  ·
  2

• MINOR: Document protocol message reader allocation limits

  docssmalltriage
  #23565·Russole opened Sep 23, 2026Contributor·

  ·

• MINOR: Speed up Streams integration test restarts

  ci-approvedsmallstreamsteststriage
  #23564·liuliuOD opened Sep 23, 2026Contributor·

  ·
  1

• KAFKA-21146 Fix BrokerTopicStats leaks in tests

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

  ·
  1

• MINOR: Allow overriding the base image of the JVM Docker image

  dockersmalltriage
  #23560·see-quick opened Sep 23, 2026Collaborator·

  ·
  2

  

• KAFKA-12986: Validate throttled replica entries before parsing

  coresmallstoragetriage
  #23559·AkshathaTR13 opened Sep 23, 2026·

  ·
  1

• KAFKA-21143: Server-only OAUTHBEARER listener with private JWKS CA triggers token login and fails broker startup

  ci-approvedclientscoresmall
  #23557·muralibasani opened Sep 22, 2026Contributor·

  ·
  1

• KAFKA-21140: Add randomized testbed for streams group task assignors

  group-coordinatorteststriage
  #23556·gabriellefu opened Sep 22, 2026Contributor·

  ·

• KAFKA-19818: Move ClientQuotaMetadataManager to metadata module

  buildcorekrafttriage
  #23555·majialoong opened Sep 22, 2026Collaborator·

  ·

• MINOR: Fix grammar in Streams DSL documentation

  docssmalltriage
  #23554·AkshathaTR13 opened Sep 22, 2026·

  ·
  1

• KAFKA-20667: Add principal-level ACL index with loop guards and bounded principal cache

  krafttriage
  #23550·Chhida opened Sep 22, 2026·

  ·

• KAFKA-21070: Fix task cleanup when state updater shutdown is interrupted

  streamstriage
  #23549·sunm2n opened Sep 22, 2026Contributor·

  ·

• KAFKA-18536: Wait for quotas before starting replication in tests

  coresmallteststriage
  #23548·akhileshchg opened Sep 21, 2026Contributor·

  ·

• KAFKA-20237: Stuck transaction manager after ssl handshake failure

  clientsproducertriage
  #23547·ezhou413 opened Sep 21, 2026Contributor·

  ·

• KAFKA-19028: Expose deleted configs to AlterConfigPolicy without changing configs()

  clientskraftsmalltriage
  #23545·arnabnandy7 opened Sep 21, 2026Contributor·

  ·
  1

• KAFKA-20924: Introduce Request Header v3 and use it for OffsetDelete v1

  ci-approvedclientsconsumergeneratorproducer
  #23544·alanlau28 opened Sep 21, 2026Contributor·

  ·
  14

• KAFKA-21136: fix pid lookup for native process

  ci-approvedsmallteststriage
  #23537·gaurav-narula opened Sep 21, 2026Contributor·

  ·

• KAFKA-21106: Address review comments

  clientsconsumerKIP-932
  #23532·AndrewJSchofield opened Sep 21, 2026Member·

  ·
  5

• KAFKA-15104: Fix flaky tests in MetadataQuorumCommandTest

  smallteststoolstriage
  #23531·egyedt opened Sep 21, 2026Contributor·

  ·
  2

• KAFKA-21102: Soften the validation for group upgrade and downgrade paths

  group-coordinator
  #23530·suzhiking opened Sep 21, 2026Contributor·

  ·
  3

• KAFKA-21110: Document that min.insync.replicas is bounded by the replica count

  clientssmall
  #23529·lucliu1108 opened Sep 20, 2026Collaborator·

  ·