All pull requests

Pull requests

• KAFKA-21026: Add JMH benchmark for the streams group heartbeat

  performancetriage
  #24101·suzhiking opened Nov 3, 2026Contributor·

  ·

• KAFKA-21369: Make Metrics.close() idempotent

  clientssmalltriage
  #24100·arxhr007 opened Nov 3, 2026Contributor·

  ·

• MINOR: Reject invalid sizes in Utils byte-array helpers

  clientssmalltriage
  #24099·arxhr007 opened Nov 3, 2026Contributor·

  ·
  1

• KAFKA-17218: Handle deleted topics in kafka-consumer-groups --describe

  ci-approvedsmalltoolstriage
  #24098·mingyen066 opened Nov 3, 2026Collaborator·

  ·

• KAFKA-21406: Document controller mutation quota metrics

  docssmalltriage
  #24097·Russole opened Nov 3, 2026Contributor·

  ·

• KAFKA-21418: Cleanup DelegationTokenCache and CredentialCache

  clientscore
  #24093·FrankYang0529 opened Nov 3, 2026Member·

  ·

• KAFKA-20734: Return noNode for known partitions without endpoints

  #24092·jolshan opened Nov 2, 2026Member·

  ·

• KAFKA-21419: Keep still-adding replicas in addingReplicas when a KRaft reassignment is overridden

  krafttoolstriage
  #24091·acgtun opened Nov 2, 2026·

  ·
  1

• MINOR: Break process load ties by process id in the streams sticky assignor

  group-coordinatorsmalltriage
  #24090·gabriellefu opened Nov 2, 2026Collaborator·

  ·

• KAFKA-21415: Backport cleanups in AlterConfig

  #24089·gaurav-narula opened Nov 2, 2026Contributor·

  ·
  4

• More library bumps

  builddependenciessmalltriage
  #24088·winfriedgerlach opened Nov 2, 2026Contributor·

  ·

• KAFKA-21412: Remove unused methods from server-common Json

  ci-approvedcoresmalltriage
  #24085·tunchungcheng opened Nov 2, 2026·

  ·

• KAFKA-21412: Remove unused methods from server-common Json

  coresmalltriage
  #24082·farheen-shaikh0509 opened Nov 2, 2026·

  ·

• MINOR: Use orElseGet for the topology fallback in StreamsGroup describe

  group-coordinatorsmall
  #24081·dajac opened Nov 2, 2026Member·

  ·
  1

• MINOR: Check topic dictionary index in AssignmentInfo

  ci-approvedsmallstreams
  #24080·aashish-confluent opened Nov 2, 2026Contributor·

  ·
  6

• KAFKA-21403: Add mirror state decoder to kafka-dump-log.sh

  buildtoolstriage
  #24078·Jayteeps opened Nov 2, 2026Contributor·

  ·
  4

• KAFKA-21404: Add MirrorStateMessageFormatter

  buildtoolstriage
  #24077·Jayteeps opened Nov 2, 2026Contributor·

  ·
  4

• MINOR: Add missing @Override annotations in clients

  ci-approvedclientssmalltriage
  #24076·ankitflow001 opened Nov 2, 2026·

  ·
  1

• MINOR: Avoid duplicate error headers in Streams DLQ records

  smallstreamstriage
  #24075·aashish-confluent opened Nov 2, 2026Contributor·

  ·

• MINOR: ChunkedBytesStream must not advertise mark/reset support

  clientssmalltriage
  #24073·Huang-404-Q opened Nov 2, 2026·

  ·

• KAFKA-21410: Do not seed aborted transactions that ended before the cleaning start

  smallstorage
  #24072·cheeeee opened Nov 2, 2026Contributor·

  ·
  4

• KAFKA-21366: Add committed-offsets filter to ListGroups (KIP-1388)

  clientscoregroup-coordinatortriage
  #24071·NicoleYWDu opened Nov 2, 2026·

  ·
  1

• KAFKA-21296: Apply default login timeouts for OAuth token requests

  clientstriage
  #24070·nileshkumar3 opened Nov 1, 2026Contributor·

  ·

• KAFKA-15923: Add TransactionLastUpdateTimeMs to DescribeTransactions (KIP-994)

  clientscoretoolstriage
  #24068·1123 opened Nov 1, 2026·

  ·

• MINOR: Offset expiration metric counts records of other groups

  group-coordinatorsmall
  #24067·dajac opened Nov 1, 2026Member·

  ·
  1