Google Git
Sign in
apache/kafka/HEAD
  1. 58d208f KAFKA-20282: Add message to classic consumer startup guiding to next-gen protocol (#21900) by Lianet Magrans · 3 hours ago trunk
  2. 7303c1e KAFKA-20366: Add syntax highlighting across docs, excluding security and streams (#21887) by gomudayya · 3 hours ago
  3. 6918a56 KAFKA-20382: Send background error when updating assignment for callbacks fail (#21919) by Lianet Magrans · 7 hours ago
  4. 4e3e685 KAFKA-19752 Move parts of UnifiedLogTest to storage module (#21912) by Ken Huang · 8 hours ago
  5. 98e13b7 MINOR: Move TerseFailure to server-common (#21890) by Ken Huang · 14 hours ago
  6. 4becf48 MINOR:Remove explicit flushes from RocksDBStores (#21871) by Eduwer Camacaro · 19 hours ago
  7. b803e8b KAFKA-20329: Test headers dsl.store.format further (2/N) (#21812) by Alieh Saeedi · 20 hours ago
  8. e2154fe MINOR: Cleanups in LogManager (#21916) by Mickael Maison · 24 hours ago
  9. f55073b KAFKA-13499: Avoid restoring outdated records (#21901) by gabriellefu · 25 hours ago
  10. d84e19d KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized (#21884) by Eduwer Camacaro · 25 hours ago
  11. feba1af MINOR: Test Coverage for Segmented stores (#21860) by Eduwer Camacaro · 25 hours ago
  12. 8956d38 MINOR: Sort reviewer candidates by contribution count (#21908) by Ming-Yen Chung · 27 hours ago
  13. 9812461 MINOR: Bump requests from 2.32.4 to 2.33.0 in /.github/scripts (#21875) by dependabot[bot] · 33 hours ago
  14. 07c87a8 KAFKA-19752 Move parts of UnifiedLogTest to storage module (#21807) by Ken Huang · 33 hours ago
  15. 1697a7b KAFKA-20316 Rewrite AddPartitionsTest with ClusterInstance (#21903) by Lan Ding · 34 hours ago
  16. 0fd8327 KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers (#21800) by nileshkumar3 · 35 hours ago
  17. 67d1e22 KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes (#21379) by Ken Huang · 2 days ago
  18. a35d649 KAFKA-19851; Delete dynamic configs that were removed by Kafka (#21053) by Zhiyan Tang · 2 days ago
  19. b347f4b KAFKA-20297 move ImplicitLinkedHashCollection, ImplicitLinkedHashMultiCollection, and ByteUtils from utils to internals (#21856) by Chia-Yi Chiu · 2 days ago
  20. 7ff975d MINOR: Improve shutdown logging for share consumer system tests (#21895) by Andrew Schofield · 2 days ago
  21. 5eff4ce MINOR: Replace Collections factory methods with Java 11+ equivalents in group-coordinator and part of clients (#21876) by Maros Orsak · 2 days ago
  22. a26b2fd KAFKA-18608: Add documentation for OAuth client assertion authentication (KIP-1258) (#21859) by Prabhash Kumar · 2 days ago
  23. 61299dd KAFKA-20330: Ack handling improvement on broker restart (#21824) by Andrew Schofield · 2 days ago
  24. a1c155e KAFKA-20297 Cleanup `org.apache.kafka.common.utils.CollectionUtils` (#21818) by Eric Chang · 2 days ago
  25. b4d1ca7 KAFKA-20347 Fix metric leak and JMX tag order in ShareCoordinatorMetrics (#21885) by majialong · 3 days ago
  26. 5a2d79a KAFKA-20359 Update docker image with fully qualified name (#21877) by Murali Basani · 3 days ago
  27. e4f75df MINOR: Use getAbsolutePath in LocalLog#exception (#21891) by PoAn Yang · 3 days ago
  28. 29d0ec2 KAFKA-14487 Move LogManager to storage module (#21834) by Mickael Maison · 3 days ago
  29. eb111f6 KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log (#21828) by Angelo R. · 4 days ago
  30. 20e681b KAFKA-20205: Use utils in TimestampedToHeadersWindowStoreAdapter (#21886) by PoAn Yang · 4 days ago
  31. 6fe8415 KAFKA-9195: Use Randomized State Directory Names in Streams System Tests (#21879) by Alieh Saeedi · 5 days ago
  32. 6ebc93c MINOR: simplify window-byte-store-supplier (#21829) by Matthias J. Sax · 5 days ago
  33. b42acde MINOR: Remove boilerplate code from header serializer test (#21837) by Arpit Goyal · 5 days ago
  34. 5a94cd6 KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory (#21804) by zoo-code · 5 days ago
  35. 5e509dc KAFKA-20287 : Fix CF handle leaks (#21751) by Murali Basani · 5 days ago
  36. 3fd16d0 KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers (#21802) by ChickenchickenLove · 5 days ago
  37. 73cb15e KAFKA-16600: Add unit test for idempotent PENDING_SHUTDOWN state transition (#21671) by Kirk True · 5 days ago
  38. 1b69c09 KAFKA-15630: Improve documentation of offset.lag.max (#21357) by Kondrat Bertalan · 5 days ago
  39. 9d1c93b MINOR: Various cleanups in raft module (#21883) by Mickael Maison · 5 days ago
  40. 69f7515 KAFKA-20106 [2/2]: Ensure reconciled assignment updated within poll KS (#21813) by Lianet Magrans · 5 days ago
  41. de7e0eb KAFKA-20267: Move LogCleanerParameterizedIntegrationTest to storage module (#21657) by Maros Orsak · 5 days ago
  42. 58b56c2 KAFKA-15853: [1/N] Move static methods, SocketServer and Log configs to AbstractKafkaConfig (#21548) by Christo Lolov · 6 days ago
  43. f93ffeb KAFKA-20360 Upgrade ducktape from 0.13 to 0.14 and requests from 2.32.2 to 2.32.4 (#21878) by Murali Basani · 6 days ago
  44. 4d3c658 KAFKA-19541; Allow configuration of kraft RPC max bytes (#21028) by Jonah Hooper · 6 days ago
  45. ccd8330 KAFKA-20355: Invalid formatting of System Properties in website (#21874) by gomudayya · 6 days ago
  46. 3c42359 KAFKA-19752: Move UnifiedLogTest to storage module (#21844) by TaiJuWu · 6 days ago
  47. 949f1a7 MINOR: Cleanups in Tools module (#21823) by Sanskar Jhajharia · 6 days ago
  48. a2c0c8b MINOR: Enable dependabot for github-actions (#21872) by Mickael Maison · 6 days ago
  49. ba96e09 KAFKA-20211, KAFKA-20345: Fix group coordinator background metrics test flake (#21770) by Sean Quah · 7 days ago
  50. 2f047be KAFKA-20340 Remove GroupConfigManager dependency from SharePartition (#21861) by majialong · 7 days ago
  51. 153a458 KAFKA-19711: Add commit-rate metric to metered state stores Add commit metric (#21853) by Bill Bejeck · 7 days ago
  52. b9882a0 KAFKA-20302: Receive buffers allocated from MemoryPool may not be released if request is invalid (#21740) by Edoardo Comar · 7 days ago
  53. 94b0f3e KAFKA-20050: Add syntax highlighting for code blocks in getting started (#21845) by gomudayya · 8 days ago
  54. 05185c1 KAFKA-20341 Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc (#21849) by Lan Ding · 9 days ago
  55. a3fae9c KAFKA-20348: Move ControllerRegistrationManager to server module (#21854) by Mickael Maison · 9 days ago
  56. 70dfc42 KAFKA-19562 Replace hand-written AbortedTxn with generated protocol (#21577) by Ming-Yen Chung · 9 days ago
  57. 994eae3 KAFKA-17840: Move ReplicationQuotaManager to server module (#21702) by Mickael Maison · 9 days ago
  58. 49bf46e MINOR: clean typos and grammar across quickstart, connect, streams, and MirrorMaker docs (#21709) by Charlie Zhang · 10 days ago
  59. 9e8bb29 MINOR: Fix default server config in BenchmarkConfigUtils (#21839) by Mickael Maison · 11 days ago
  60. f645314 MINOR: Use mutable maps in Fetch.forPartition to avoid potential UnsupportedOperationException (#21816) by Chih-Yuan Chien · 12 days ago
  61. a83dda8 KAFKA-20249: Optimize raw value extraction in headers-aware deserializers (#21706) by Zheguang Zhao · 12 days ago
  62. 826755a MINOR: improve generic type safety for IQv2 in metered-store layer (#21683) by Matthias J. Sax · 12 days ago
  63. 010f81b MINOR: Consumer tidying (#21832) by Andrew Schofield · 12 days ago
  64. 5a628e5 KAFKA-20321: Mark lost partitions before callbacks for Consumer and Streams (#21781) by Lianet Magrans · 12 days ago
  65. 93918c5 MINOR: Update supported image in docker_scan.yml (#21833) by Viktor Somogyi-Vass · 12 days ago
  66. 4ce6c04 KAFKA-20306: StreamsGroupCommand should display committed offsets for repartition topics (#21817) by Alieh Saeedi · 12 days ago
  67. bba9952 KAFKA-20326: WindowStoreMaterializerTests needs to get updated (#21825) by TengYao Chi · 13 days ago
  68. 9a28bd2 KAFKA-19542: Consumer.close() does not remove all added sensors from Metrics (#21038) by Kirk True · 13 days ago
  69. 1ad463d KAFKA-20318: Add time ordered session store support to the DSL (#21794) by Bill Bejeck · 13 days ago
  70. a69156a MINOR: refactor warning message (#21661) by Kuan-Po Tseng · 13 days ago
  71. 6ceb36f KAFKA-19752 Move UnifiedLogTest to storage module (#21761) by TaiJuWu · 13 days ago
  72. a8e9135 MINOR: Bump trunk to 4.4.0-SNAPSHOT (#21821) by Mickael Maison · 13 days ago
  73. ba0738d KAFKA-20251: Add group-level configs for assignment batching and offload (#21627) by Sean Quah · 13 days ago
  74. 4796f46 MINOR: Replace Collections factory methods with Java 11+ equivalents in storage and metadata (#21659) by Maros Orsak · 13 days ago
  75. 599d55c KAFKA-19710: Write legacy .checkpoint on close for downgrade support (#21814) by Nick Telford · 14 days ago
  76. 51fa160 KAFKA-20333: Fix flaky consumer test (#21815) by Lianet Magrans · 14 days ago
  77. a6fd96c KAFKA-20317: Enable time-ordered header window store in DSL (#21780) by TengYao Chi · 14 days ago
  78. 2401cac MINOR: add test cases for dumpLogSegments (#21538) by TaiJuWu · 14 days ago
  79. 24ce8c2 KAFKA-20291 [4/N]: Fix consumer system tests (#21811) by Sean Quah · 14 days ago
  80. a6eb6ae KAFKA-20291 [3/3]: Implement assignment batching for streams groups (#21722) by Sean Quah · 14 days ago
  81. 9be18d2 MINOR: Remove unused createNetworkClient overload in ClientUtils (#21810) by majialong · 14 days ago
  82. 0db9f32 MINOR: misc improvements in consumer test & events (#21797) by Lianet Magrans · 14 days ago
  83. 0f0b418 KAFKA-20291 [2/3]: Implement assignment batching for share groups (#21721) by Sean Quah · 14 days ago
  84. b2b240b MINOR: Revise Topic Resolving Logic in OffsetCommit Request to Prevent Race Condition (#21809) by Lucy Liu · 14 days ago
  85. 56d562d KAFKA-20258 Refactor DSL store config and propagate dslStoreFormat (#21784) by Zheguang Zhao · 14 days ago
  86. f380a04 KAFKA-20164; Add bootstrap support to KRaft listener interface (#21453) by mannoopj · 14 days ago
  87. 8b47aa8 KAFKA-17411: Fix issues with new offset management (#21795) by Nick Telford · 14 days ago
  88. f6ca0f6 MINOR: replace mkMap/mkEntry with Map.of/Map.entry in clients module (#21726) by Lan Ding · 2 weeks ago
  89. 422845f KAFKA-20291 [1/3]: Implement assignment batching for consumer groups (#21720) by Sean Quah · 2 weeks ago
  90. caa71a3 MINOR: Deflake Headers store upgrade integration test (#21808) by Alieh Saeedi · 2 weeks ago
  91. a0203dc KAFKA-20322: Add API version discovery true for transaction manager (#21782) by Ritika Reddy · 2 weeks ago
  92. a80deda KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [3/N] (#21692) by Lucy Liu · 2 weeks ago
  93. 53b1a77 KAFKA-19713: Persist Position into offsets CF (#21750) by Eduwer Camacaro · 2 weeks ago
  94. 363e4ae KAFKA-20297 move Scheduler from client common to trogdor (#21753) by Chia-Yi Chiu · 2 weeks ago
  95. 689b50b MINOR: Add 4.1.2 to system tests (#21796) by Andrew Schofield · 2 weeks ago
  96. b43d708 KAFKA-18652: Add `task.offset.interval.ms` config (#21737) by Matthias J. Sax · 2 weeks ago
  97. aa97adc MINOR: Cleaning DSL ops and tests (#21792) by Alieh Saeedi · 2 weeks ago
  98. e952ccd KAFKA-20173: Ensure Metered kv-stores pass headers correctly (#21768) by Matthias J. Sax · 2 weeks ago
  99. 71449aa KAFKA-20106: Ensure reconciled assignment updated within poll (#21495) by Lianet Magrans · 2 weeks ago
  100. 5af84cf KAFKA-20262: Changelog tombstone records drop custom headers when usi… (#21639) by TengYao Chi · 2 weeks ago