Google Git
Sign in
apache / kafka / HEAD
  1. f0488eb KAFKA-19999 Transaction coordinator livelock caused by invalid producer epoch (#21176) by Ken Huang · 17 hours ago trunk
  2. 6be062a KAFKA-15599: Move DefaultExternalKRaftMetrics to the server module (#21163) by Mickael Maison · 33 hours ago
  3. 7ff4835 MINOR: Fix the Client/Broker Forward Compatibility table in compatibility page (#21209) by Ken Huang · 3 days ago
  4. 0d9ae49 KAFKA-17302: APIs for Follower Fetch from Last Tiered Offset (#21153) by Abhijeet Kumar · 4 days ago
  5. 3a950f4 KAFKA-19752 Move UnifiedLogTest to storage module (1/N) (#20635) by TaiJuWu · 4 days ago
  6. 9f03f5b KAFKA-19993 Correct the docs of Consumer#committed about the nonexistent partition (#21196) by Lan Ding · 4 days ago
  7. a37e79a MINOR: Fix use_transactions_v2 usage in e2e (#21164) by Ming-Yen Chung · 4 days ago
  8. edd35a6 KAFKA-20017 incorrect warn log when alterConfig suceeds (#21208) by Lan Ding · 5 days ago
  9. bb300ef MINOR: Add comment about escaping '$' symbol in ConfigCommand (#21186) by Lan Ding · 6 days ago
  10. 4af6d7b MINOR: Fix typo in broker-configs.md (#21203) by Lan Ding · 6 days ago
  11. fe02a74 MINOR: Remove unintentional console output in MetadataCacheTest (#21204) by Sanskar Jhajharia · 6 days ago
  12. 165b27b MINOR: Fix boolean formatting consistency in protocol definitions (#21202) by Lan Ding · 6 days ago
  13. de029ac MINOR: Remove unstable.api.version.enable config and rename corresponding test from StreamsGroupHeartbeatRequestTest (#21132) by lucliu1108 · 7 days ago
  14. 09713a3 KAFKA-19749 The `version-mapping` of kafka-features.sh should work without requiring the bootstrap (#20619) by Chang-Yu Huang · 8 days ago
  15. 78bc948 KAFKA-20013 Markdown docs for 4.3.x / trunk (#21195) by Harish Vishwanath · 9 days ago
  16. 89cc01b MINOR: Increased MiniKdc startup timeout. (#21169) by Nikita Shupletsov · 9 days ago
  17. aa016f1 KAFKA-20002: Reset-by-duration should not hand back task to state-updater (#21167) by Matthias J. Sax · 9 days ago
  18. 5316f43 KAFKA-18615: StreamThread *-ratio metrics suffer from sampling bias (#21160) by Alieh Saeedi · 9 days ago
  19. 09ead68 MINOR: replaces non-ASCII dashes with the standard ASCII hyphen (#21148) by Parker Chang · 9 days ago
  20. 19ac4ce KAFKA-20007 override exit procedure in AclCommandTest#testAclCliWithMisusingBootstrapControllerToServer (#21173) by Gaurav Narula · 9 days ago
  21. 28430c3 MINOR: Replace ClientPropertiesBuilder with admin() factory methods in KafkaClusterTestKit (#21146) by majialong · 10 days ago
  22. b3d0093 KAFKA-19995: Record copy lag metrics during failures (#21158) by Nandini Singhal · 10 days ago
  23. da3f875 MINOR: Cleanup additional dead code missed during stateupdater refactoring (#21157) by Shashank · 10 days ago
  24. da61b19 KAFKA-19981: Handle retriable remote storage exception in RemoteLogManager (#21150) by Lan Ding · 11 days ago
  25. 29ec918 MINOR: Added start await logic to verifiable consumer. (#21166) by Nikita Shupletsov · 11 days ago
  26. d785957 MINOR: code cleanup in InternalTopicManager (#21165) by Matthias J. Sax · 11 days ago
  27. a2eae88 KAFKA-19940 Reduce the log4j2 cpu usage in PersisterStateManager (#21027) by Ken Huang · 11 days ago
  28. c284a92 KAFKA-19990 gracefully handle exceptions when handling AllocateProducerIdsResponse (#21135) by Gaurav Narula · 11 days ago
  29. be6f22f MINOR: change updateBrokerConfig and updateDefaultConfig error message (#21162) by TaiJuWu · 11 days ago
  30. bf91c07 KAFKA-15599: Move KafkaMetadataLog to the raft module (#19762) by Mickael Maison · 12 days ago
  31. bd0c628 KAFKA-19994: TaskManager may not close all tasks on task timeouts (#21155) by Lucas Brutschy · 13 days ago
  32. 95d164a MINOR: improve logging (#21147) by Matthias J. Sax · 13 days ago
  33. 08aadb7 KAFKA-19987: Add metrics from KIP-1216 to ops.html (#21130) by Lucas Brutschy · 14 days ago
  34. f75079b KAFKA-19985: Document streams groups metrics changes in ops.html (#21129) by Lucas Brutschy · 14 days ago
  35. 7d13e8b KAFKA-17573 Move KRaftMetadataCache to metadata module (#19232) by PoAn Yang · 2 weeks ago
  36. 9273cdc MINOR: Bytes lexicographic comparator could use compiler builtin (#21073) by Steven Schlansker · 2 weeks ago
  37. 25a8ae0 KAFKA-17266: Add dynamic broker config to enable follower fetch using tiered offset (#16834) by Abhijeet Kumar · 2 weeks ago
  38. 06a744a KAFKA-19980 ConfigCommand#validatePropsKey should accept `$` symbol (#21125) by Lan Ding · 2 weeks ago
  39. 89aa87c KAFKA-19809 CheckStyle version upgrade: 10 -->> 12 (#20726) by Dejan Stojadinović · 2 weeks ago
  40. b825af5 KAFKA-19755 Move KRaftClusterTest from core module to server module [2/4] (#20861) by Lan Ding · 2 weeks ago
  41. 157409c MINOR: Introduce TopicRegexResolver and Move Regex Resolution Logic Out of GroupMetadataManager (#21103) by Aneesh Garg · 2 weeks ago
  42. dbbb9c7 KAFKA-19959: Update session and window store with new default when no open iterators (#21120) by Bill Bejeck · 2 weeks ago
  43. cb9280e KAFKA-19519 Introduce group/share.coordinator.cached.buffer.max.bytes config (#20847) by Lan Ding · 2 weeks ago
  44. 58e136c MINOR: Scala, Scalafmt and Scalac SCoverage plugin version updates (#21086) by Dejan Stojadinović · 2 weeks ago
  45. d4e7b9b MINOR: Bump maven artifact lib and remove commonsLang (#21115) by Maros Orsak · 3 weeks ago
  46. 70b8af7 KAFKA-10357: Refactor makeReady to reduce complexity and support upcoming KIP-698 changes (#20326) by k-apol · 3 weeks ago
  47. c639b18 MINOR: added retries if removeMembersFromConsumerGroup failed with UnknownMemberIdException (#21074) by Nikita Shupletsov · 3 weeks ago
  48. c7f7169 KAFKA-19978: Don't enter running state as long as group is not ready (#21110) by Lucas Brutschy · 3 weeks ago
  49. d793e37 KAFKA-19678: Refactor to reset timestamp to zero when no open iterators (#21091) by Bill Bejeck · 3 weeks ago
  50. 73dc373 KAFKA-18913: Remove all code related to non-stateupdater path (#21059) by Shashank · 3 weeks ago
  51. 83dc0d7 KAFKA-19862: Group coordinator loading may fail when there is concurrent compaction (#20907) by Izzy Harker · 3 weeks ago
  52. eda14ad MINOR: Remove reused CleanOptions (#21083) by Chang-Yu Huang · 3 weeks ago
  53. fe85eb5 MINOR: Clean up ProducerStateEntry (#21096) by Dmitry Werner · 3 weeks ago
  54. 6e741ff MINOR: Extend streams quickstart with new protocol (#21093) by Evan Zhou · 3 weeks ago
  55. 499e167 KAFKA-19865: Document queues metrics changes in ops.html (#21046) by jimmy · 3 weeks ago
  56. f7e2309 KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 (#21035) by Erik Anderson · 3 weeks ago
  57. 8ff7add KAFKA-19974: Do not bump member epoch when exiting UNREVOKED_PARTITIONS (#21107) by Sean Quah · 3 weeks ago
  58. b9d6add KAFKA-15700: FetchFromFollowerIntegrationTest is flaky (#20982) by Chang-Yu Huang · 3 weeks ago
  59. c739af9 MINOR: Clean up non-existing package in spotBogs and checkstyle import rules (#21004) by Eric Chang · 3 weeks ago
  60. 33df653 KAFKA-19941 Improved property spacing/readability of kafka-features.sh output (#21072) by Rion Williams · 3 weeks ago
  61. 46785f1 KAFKA-19966 Upgrade commons-validator to 1.10.1 (#21082) by Lan Ding · 3 weeks ago
  62. 71299c2 KAFKA-19972: Bump delivery count on session release (#21092) by Apoorv Mittal · 3 weeks ago
  63. f662350 MINOR: Fix Formatting in `ConsumerGroupHeartbeatRequestTest.scala` (#21087) by Aneesh Garg · 3 weeks ago
  64. 963d54a KAFKA-19945: Always set status field in StreamsGroupHeartbeat response (#21031) by Lucas Brutschy · 3 weeks ago
  65. 7c4ae09 MINOR: Fix a typo in connect.html (#21076) by Joanna-D · 3 weeks ago
  66. 13c89e8 KAFKA-19965: Increasing batch size to fix throttled delivery test (#21081) by Apoorv Mittal · 3 weeks ago
  67. a8b1fb9 KAFKA-19777 : Generator | Fix order of arguments to assertEquals in unit tests - 2 (#21012) by Ibuki Kaji · 3 weeks ago
  68. ad3f727 MINOR: Clean up UniformHeterogeneousAssignmentBuilderTest (#21067) by Sean Quah · 3 weeks ago
  69. 6538120 MINOR: Rename OptimizedUniformAssignmentBuilderTest (#21066) by Sean Quah · 3 weeks ago
  70. 6f1a6ae MINOR: Clean up coordinator runtime metrics isolation tests (#21043) by Sean Quah · 3 weeks ago
  71. 97510ff MINOR: Fix assignment reuse tests (#21077) by Sean Quah · 3 weeks ago
  72. c7bdabf KAFKA-19286: Fix flaky testConcurrentRemoveReadForCache1 (#20893) by Uladzislau Blok · 3 weeks ago
  73. d31dfa0 MINOR: Fix typo in MemberAssignmentImplTest (#21070) by Sean Quah · 3 weeks ago
  74. ad2845f KAFKA-8080: Remove streams_eos_test system test (#21030) by Jinhe Zhang · 4 weeks ago
  75. 82241e1 KAFKA-19891: Bump group epoch when member regex subscription transitions from non-empty to empty (#21013) by Anton Vasanth · 4 weeks ago
  76. 10ebba5 MINOR: Add tests for assignor stability and assignment reuse (#21069) by Sean Quah · 4 weeks ago
  77. 54e629e MINOR: Add test for Assignment immutability (#21068) by Sean Quah · 4 weeks ago
  78. 70be719 KAFKA-19950: Mark session stale when removed prior disconnection event (#21062) by Apoorv Mittal · 4 weeks ago
  79. 051fb66 KAFKA-19938: Fix combined node log dir format in KafkaClusterTestKit (#21017) by Mickael Maison · 4 weeks ago
  80. e4795bf KAFKA-19900: Fix the documentation for remove controller (#20931) by Paolo Patierno · 4 weeks ago
  81. 275c944 KAFKA-19956: Fix flaky testRemoteAssignorRange (#21060) by Lianet Magrans · 4 weeks ago
  82. a9dff62 KAFKA-19955: Fix performance regression in server-side assignors (#21058) by Sean Quah · 4 weeks ago
  83. 917d695 KAFKA-17019 Producer TimeoutException should include root cause (#20159) by ChickenchickenLove · 4 weeks ago
  84. fd5d923 MINOR: Add Security section to Connect docs (#21056) by Mickael Maison · 4 weeks ago
  85. 064dd5f MINOR: Require non-null arguments to GroupCoordinatorService#onMetadataUpdate (#21052) by David Jacot · 4 weeks ago
  86. 3e3f0c4 KAFKA-19946: Simplify skipping of empty ShareFetch requests (#21033) by Andrew Schofield · 4 weeks ago
  87. c9fa8c5 KAFKA-19944: kafka-share-groups.sh describe offsets message improvement (#21024) by Andrew Schofield · 4 weeks ago
  88. 43062a0 KAFKA-19957: Accumulate offsets response in same batch (#21061) by Apoorv Mittal · 4 weeks ago
  89. be368b3 MINOR: Improve GroupCoordinatorService#onPartitionsDeleted path (#21055) by David Jacot · 4 weeks ago
  90. 18dbd52 KAFKA-19954: Fixing overlapping batches post re-initalization of Share Partition (#21051) by Apoorv Mittal · 4 weeks ago
  91. eac1930 MINOR: Add more unit tests to test GAP Acknowledgements in ShareCompletedFetch (#21044) by Shivsundar R · 4 weeks ago
  92. 55d557c KAFKA-19942: Clean up StreamThread and StoreChangelogReader Test (#21022) by Shashank · 4 weeks ago
  93. dfa28c4 KAFKA-19953: Bug releasing acquired records when maintained per offset (#21050) by Abhinav Dixit · 4 weeks ago
  94. 4e075e9 MINOR: Deduplicate common test helpers in group-coordinator tests (#21047) by Aneesh Garg · 4 weeks ago
  95. f83a871 MINOR: Update `ShareCoordinator` interface to received `MetadataImage/Delta` directly (#21029) by David Jacot · 4 weeks ago
  96. 2db09f6 MINOR: Rename CoordinatorShard#onNewMetadataImage to onMetadataUpdate (#21032) by David Jacot · 4 weeks ago
  97. 630857c MINOR: Add Gradle task to verify ASF license header in JSON files (#20825) by Ming-Yen Chung · 4 weeks ago
  98. 6322bd1 KAFKA-18786 add nodeId to DescribeFeaturesOptions (#20674) by PoAn Yang · 4 weeks ago
  99. 29e38c1 MINOR: Streams developer guide improvement (#21000) by Evan Zhou · 4 weeks ago
  100. a7246ff MINOR: improve Kafka Streams transform upgrade docs (#21002) by Matthias J. Sax · 4 weeks ago