Commits

Branch selector

 trunk

User selector

All users

All time

Commit History

Commits on Dec 3, 2025

• KAFKA-19946: Simplify skipping of empty ShareFetch requests (#21033)

  Show description for 3e3f0c4
  AndrewJSchofield

  authored
  3e3f0c4

  Copy full SHA for 3e3f0c4

• KAFKA-19944: kafka-share-groups.sh describe offsets message improvement (#21024)

  Show description for c9fa8c5
  AndrewJSchofield

  authored
  c9fa8c5

  Copy full SHA for c9fa8c5

• KAFKA-19957: Accumulate offsets response in same batch (#21061)

  Show description for 43062a0
  apoorvmittal10

  authored
  43062a0

  Copy full SHA for 43062a0

• MINOR: Improve GroupCoordinatorService#onPartitionsDeleted path (#21055)

  Show description for be368b3
  dajac

  authored
  be368b3

  Copy full SHA for be368b3

Commits on Dec 2, 2025

• KAFKA-19954: Fixing overlapping batches post re-initalization of Share Partition (#21051)

  Show description for 18dbd52
  apoorvmittal10

  authored
  18dbd52

  Copy full SHA for 18dbd52

• MINOR: Add more unit tests to test GAP Acknowledgements in ShareCompletedFetch (#21044)

  Show description for eac1930
  ShivsundarR

  authored
  eac1930

  Copy full SHA for eac1930

• KAFKA-19942: Clean up StreamThread and StoreChangelogReader Test (#21022)

  Show description for 55d557c
  

  3 peopleauthored
  55d557c

  Copy full SHA for 55d557c

• KAFKA-19953: Bug releasing acquired records when maintained per offset (#21050)

  Show description for dfa28c4
  adixitconfluent

  authored
  dfa28c4

  Copy full SHA for dfa28c4

• MINOR: Deduplicate common test helpers in group-coordinator tests (#21047)

  Show description for 4e075e9
  AnGg98

  authored
  4e075e9

  Copy full SHA for 4e075e9

• MINOR: Update `ShareCoordinator` interface to received `MetadataImage/Delta` directly (#21029)

  Show description for f83a871
  dajac

  authored
  f83a871

  Copy full SHA for f83a871

• MINOR: Rename CoordinatorShard#onNewMetadataImage to onMetadataUpdate (#21032)

  Show description for 2db09f6
  dajac

  authored
  2db09f6

  Copy full SHA for 2db09f6

• MINOR: Add Gradle task to verify ASF license header in JSON files (#20825)

  Show description for 630857c
  mingyen066

  authored
  630857c

  Copy full SHA for 630857c

• KAFKA-18786 add nodeId to DescribeFeaturesOptions (#20674)

  Show description for 6322bd1
  FrankYang0529

  authored
  6322bd1

  Copy full SHA for 6322bd1

• MINOR: Streams developer guide improvement (#21000)

  Show description for 29e38c1
  ezhou413

  authored
  29e38c1

  Copy full SHA for 29e38c1

Commits on Dec 1, 2025

• MINOR: improve Kafka Streams transform upgrade docs (#21002)

  Show description for a7246ff
  mjsax

  authored
  a7246ff

  Copy full SHA for a7246ff

• KAFKA-19683: Clean up TaskManagerTest (#20994)

  Show description for ea88a8e
  shashankhs11

  authored
  ea88a8e

  Copy full SHA for ea88a8e

• MINOR: Code cleanup and additional tests for DefaultJwtValidator

  

  kirktrue

  authored and

  omkreddy

  committed
  4836ed7

  Copy full SHA for 4836ed7

• KAFKA-19930: Adding process handler null check for global threads (#21016)

  Show description for 7cea059
  iit2009060

  authored
  7cea059

  Copy full SHA for 7cea059

Commits on Nov 30, 2025

• KAFKA-19928: Added retry and backoff mechanism in NetworkPartitionMetadataClient (#21001)

  Show description for ed3af72
  chirag-wadhwa5

  authored
  ed3af72

  Copy full SHA for ed3af72

• MINOR: Update `GroupCoordinator` interface to received `MetadataImage/Delta` directly (#21008)

  Show description for e9ff2cc
  dajac

  authored
  e9ff2cc

  Copy full SHA for e9ff2cc

Commits on Nov 29, 2025

• MINOR: remove flaky tag from stable test (#21018)

  Show description for 0e1c6fb
  lianetm

  authored
  0e1c6fb

  Copy full SHA for 0e1c6fb

Commits on Nov 28, 2025

• KAFKA-19926: Apply rebalance delay also for later epochs if the group is empty (#21011)

  Show description for 65a3bd2
  RaidenE1

  authored
  65a3bd2

  Copy full SHA for 65a3bd2

• KAFKA-19634 Formalize nullable and non-nullable type distinctions in protocol specification (#20614)

  Show description for 58d62d1
  DL1231

  authored
  58d62d1

  Copy full SHA for 58d62d1

• KAFKA-19929: Fix polling delay for share consumer in record-limit mode (#21007)

  Show description for 7311fe5
  AndrewJSchofield

  authored
  7311fe5

  Copy full SHA for 7311fe5

• MINOR: Rename CoordinatorRuntime.activeTopicPartitions to activeCoordinators (#21010)

  Show description for af934aa
  dajac

  authored
  af934aa

  Copy full SHA for af934aa

• MINOR: Move ShareAcquireMode to consumer.internal package (#20973)

  Show description for a9cc8f2
  JimmyWang6

  authored
  a9cc8f2

  Copy full SHA for a9cc8f2

Commits on Nov 27, 2025

• MINOR: Refactor OffsetFetch path (#21009)

  Show description for d27d90c
  dajac

  authored
  d27d90c

  Copy full SHA for d27d90c

• MINOR: Add missing log4j2.yaml file for some modules (#20821)

  Show description for 98b11d7
  TaiJuWu

  authored
  98b11d7

  Copy full SHA for 98b11d7

• KAFKA-19927: Add retry for network and req timeout resp errors. (#20998)

  Show description for 5dd0153
  smjn

  authored
  5dd0153

  Copy full SHA for 5dd0153

• KAFKA-19380: Update streams/developer-guide/app-reset-tool.html (#20946)

  Show description for c274374
  aliehsaeedii

  authored
  c274374

  Copy full SHA for c274374

Commits on Nov 26, 2025

• KAFKA-19589: Check for ability to skip position validation in application thread when collecting buffered data (#20324)

  Show description for 51bb036
  kirktrue

  authored
  51bb036

  Copy full SHA for 51bb036

• MINOR: Correct ShareCoordinatorMetrics comments and sensor name constant (#20999)

  Show description for 01cc865
  majialoong

  authored
  01cc865

  Copy full SHA for 01cc865

• KAFKA-19888: Clamp negative values in coordinator histograms (#20986)

  Show description for 889c3d4
  squah-confluent

  authored
  889c3d4

  Copy full SHA for 889c3d4

• KAFKA-19683: Final test replacements [8/N] (#20944)

  Show description for e04fd9d
  shashankhs11

  authored
  e04fd9d

  Copy full SHA for e04fd9d

• KAFKA-19924: Ensure deterministic task order by using TreeSet in TaskManager (#20992)

  Show description for c93e379
  shashankhs11

  authored
  c93e379

  Copy full SHA for c93e379