Google Git
Sign in
apache / kafka / HEAD
  1. 81c222e KAFKA-16613 remove TestUtils#subscribeAndWaitForRecords (#15794) by PoAn Yang · 9 hours ago trunk
  2. b8b2415 KAFKA-16592 Add a new constructor which invokes the existing constructor with default value for alternativeString (#15762) by vamossagar12 · 15 hours ago
  3. 960794a KAFKA-16483 migrate DeleteOffsetsConsumerGroupCommandIntegrationTest to use ClusterTestExtensions (#15679) by PoAn Yang · 17 hours ago
  4. a8c0f2b KAFKA-16605: Fix the flaky LogCleanerParameterizedIntegrationTest (#15787) by Kamal Chandraprakash · 18 hours ago
  5. a381852 KAFKA-16424: remove truncated logs after alter dir (#15616) by PoAn Yang · 18 hours ago
  6. cfe5ab5 KAFKA-15853 Move quota configs into server-common package (#15774) by Omnia Ibrahim · 23 hours ago
  7. b6e70e9 MINOR: Add test for PartitionMetadataFile (#15714) by Cheng-Kai, Zhang · 23 hours ago
  8. 1b301b3 KAFKA-15853 Move socket configs into org.apache.kafka.network.SocketServerConfigs (#15772) by Omnia Ibrahim · 2 days ago
  9. e6b6b6c MINOR: Remove extra "}" logged in KafkaStreams close (#15783) by Gyeongwon, Do · 2 days ago
  10. 53f9675 KAFKA-16461: New consumer fails to consume records in security_test.py system test (#15746) by Kirk True · 2 days ago
  11. 18572f5 MINOR: Reduce the time taken to execute the TieredStorage tests. (#15780) by Kamal Chandraprakash · 2 days ago
  12. b254e78 KAFKA-16466: Log exception message for non-fault errors in QuorumController (#15701) by ilyazr · 2 days ago
  13. 59c7814 MINOR: Fix io-[wait-]ratio metrics description (#15722) by Eugene Mitskevich · 3 days ago
  14. fb529d8 KAFKA-16548 Avoid decompressing/collecting all records when all we want to do is to find a single matched record from remote storage (#15765) by Ken Huang · 3 days ago
  15. 1763fe1 KAFKA-16549 suppress the warnings from RemoteLogManager (#15767) by charliecheng630 · 3 days ago
  16. c519c5c MINOR: use assertInstanceOf to replace assertTrue (#15769) by Yu-Chen Lai · 3 days ago
  17. f9f65b9 MINOR: example.com moved (#15758) by Andras Katona · 3 days ago
  18. ed47e37 KAFKA-16103: AsyncConsumer should await pending async commits on commitSync and close (#15613) by Lucas Brutschy · 3 days ago
  19. e4d34dd MINOR: Fix CDS in docker image (#15771) by Vedarth Sharma · 3 days ago
  20. 5e96e5c KAFKA-15853 Refactor KafkaConfig to use PasswordEncoderConfigs (#15770) by Omnia Ibrahim · 3 days ago
  21. 98548c5 KAFKA-16591 Clear all admins after close all them. (#15763) by TingIāu "Ting" Kì · 4 days ago
  22. 34f65d3 MINOR: Fixed incorrect references for SASL_OAUTHBEARER_SCOPE_CLAIM_NAME_DEFAULT and SASL_OAUTHBEARER_SUB_CLAIM_NAME_DEFAULT (#15760) by TingIāu "Ting" Kì · 4 days ago
  23. ced79ee KAFKA-16552 Create an internal config to control InitialTaskDelayMs in LogManager to speed up tests (#15719) by Kuan-Po (Cooper) Tseng · 5 days ago
  24. 613d4c8 MINOR: fix hint in fetchOffsetForTimestamp (#15757) by hudeqi · 5 days ago
  25. 0308543 KAFKA-16082 Avoid resuming future replica if current replica is in the same directory (#15136) by Gaurav Narula · 5 days ago
  26. ecb2dd4 KAFKA-15853 Move KafkaConfig log properties and docs out of core (#15569) by Omnia Ibrahim · 5 days ago
  27. 76e0891 KAFKA-16486: Integrate KIP-1019 measurability changes (KIP-714) (#15682) by Apoorv Mittal · 5 days ago
  28. f22ad66 KAFKA-16272: Adding new coordinator related changes for connect_distributed.py (#15594) by vamossagar12 · 6 days ago
  29. b87cd66 KAFKA-16579: Revert Consumer Rolling Upgrade (#15753) by Philip Nee · 6 days ago
  30. 9ea0503 KAFKA-16566: Fix consumer static membership system test with new protocol (#15738) by Lianet Magrans · 6 days ago
  31. 8f2fca7 MINOR: Use Parametrized types correctly in RemoteLogMetadataSerde (#13824) by Josep Prat · 6 days ago
  32. 5783159 MINOR: disable internal result emit throttling in TTD (#15660) by Matthias J. Sax · 6 days ago
  33. 5d3f867 KAFKA-16280: Expose method to determine metric measurability (KIP-1019) (#15681) by Apoorv Mittal · 6 days ago
  34. 53ff1a5 KAFKA-15585: DescribeTopicPartitions client side change. (#15470) by Calvin Liu · 6 days ago
  35. aee9724 MINOR: Remove unneeded explicit type arguments (#15736) by Mickael Maison · 7 days ago
  36. a3dcbd4 KAFKA-16073: Increment the local-log-start-offset before deleting segments in memory table (#15631) by Kamal Chandraprakash · 7 days ago
  37. e63efbc MINOR: fix duplicated return and other streams docs typos (#15713) by Ayoub Omari · 8 days ago
  38. 7b1c777 MINOR: Various cleanups in connect (#15734) by Mickael Maison · 8 days ago
  39. 363f4d2 KAFKA-15853 Move consumer group and group coordinator configs out of core (#15684) by Omnia Ibrahim · 8 days ago
  40. a9f65a5 KAFKA-16436; Online upgrade triggering and group type conversion (#15662) by Dongnuo Lyu · 8 days ago
  41. be18775 MINOR: adds '-parameters' compiler option for :core tests (#15729) by Nikolay · 8 days ago
  42. 4419698 KAFKA-16363 Storage tool crashes if dir is unavailable (#15733) by Michael Westerby · 8 days ago
  43. 4954c57 KAFKA-16559 allow defining number of disks per broker in TestKitNodes (#15730) by Gaurav Narula · 8 days ago
  44. 5193eb9 KAFKA-16475: add test for TopicImageNodeTest (#15720) by Johnny Hsu · 8 days ago
  45. 4e1a23d MINOR: Fix typo in OffsetCommitCallbackInvoker's javadoc (#15643) by Gyeongwon, Do · 8 days ago
  46. 6ed3bae MINOR: Fix a few typos in clients and core tests (#15725) by lixinyang · 8 days ago
  47. 269b457 MINOR: Add missing docs for migration metrics (#15718) by Igor Soarez · 9 days ago
  48. fccd7fe MINOR: Various cleanups in clients (#15705) by Mickael Maison · 9 days ago
  49. ebeef4e KAFKA-16556: SubscriptionState should not prematurely reset 'pending' partitions (#15724) by Kirk True · 9 days ago
  50. a1ca788 KAFKA-15517: Improve MirrorMaker logging in case of authorization errors (#15558) by Dmitry Werner · 9 days ago
  51. f7eb962 MINOR: Replaced the while loop with TestUtils.waitForCondition (#15678) by John Yu · 9 days ago
  52. 8c04588 KAFKA-15853 Move KafkaConfig Replication properties and docs out of … (#15575) by Omnia Ibrahim · 9 days ago
  53. 2b9729b MINOR: Various cleanups in server and server-common (#15710) by Mickael Maison · 9 days ago
  54. 395fdae MINOR: Various cleanups in tools (#15709) by Mickael Maison · 10 days ago
  55. 3617dda MINOR: Various cleanups in storage (#15711) by Mickael Maison · 10 days ago
  56. 49e7c79 KAFKA-16490 Upgrade gradle from 8.6 to 8.7 (#15716) by John Yu · 10 days ago
  57. 4caf888 MINOR: Various cleanups in trogdor (#15708) by Mickael Maison · 10 days ago
  58. 437ebb9 KAFKA-15729 Add KRaft support in GetOffsetShellTest (#15489) by Owen Leung · 11 days ago
  59. 0b4e9af MINOR: Various cleanups in shell (#15712) by Mickael Maison · 11 days ago
  60. c034cf2 MINOR: Fix incorrect Java equals comparison of Uuid by reference (#15707) by Alok Thatikunta · 12 days ago
  61. e02ffd8 KAFKA-16463 Delete metadata log on ZK broker startup (#15648) by David Arthur · 12 days ago
  62. 61baa7a KAFKA-15853 Move transactions configs out of core (#15670) by Omnia Ibrahim · 12 days ago
  63. 31171d0 MINOR: Document JBOD limitation during migration (#15692) by Igor Soarez · 13 days ago
  64. 15c4ade MINOR: Improve logging in AssignmentsManager (#15522) by Igor Soarez · 13 days ago
  65. a50ea8d KAFKA-16473: Use correct cluster ID when formatting log dir. (#15658) by Sebastian Marsching · 13 days ago
  66. 753cc4b MINOR: Update docs link to deprecated method TimeWindows.grace (#15700) by Ayoub Omari · 13 days ago
  67. 315cd83 MINOR: remove redundant argument in log (#15699) by Kuan-Po (Cooper) Tseng · 13 days ago
  68. b67a3fa KAFKA-16509: CurrentControllerId metric is unreliable in ZK mode (#15695) by Colin Patrick McCabe · 13 days ago
  69. 4aba807 KAFKA-15610 Fix CoreUtils.swallow() test gaps (#15410) by ghostspiders · 14 days ago
  70. 72b823e KAFKA-16482 Eliminate the IDE warnings of accepting ClusterConfig in BeforeEach (LeaderElectionCommandTest and ProducerIdsIntegrationTest) (#15676) by Cheng-Kai, Zhang · 14 days ago
  71. 619f270 KAFKA-16294: Add group protocol migration enabling config (#15411) by Dongnuo Lyu · 2 weeks ago
  72. dc9fbe4 KAFKA-16389: ConsumerEventHandler does not support incremental assignment changes causing failure in system test (#15661) by Philip Nee · 2 weeks ago
  73. e2e2f82 KAFKA-15853 Move Sasl and SSL configs out of core (#15656) by Omnia Ibrahim · 2 weeks ago
  74. f6c9fee KAFKA-16297: Race condition while promoting future replica (#15557) by Igor Soarez · 2 weeks ago
  75. e5a3f99 KAFKA-16433: BeginningAndEndOffsets and OffsetsForTimes should send an event and return empty with zero timeout provided (#15688) by Philip Nee · 2 weeks ago
  76. 9bc48af MINOR: Add type check to classic group timeout operations (#15587) by Dongnuo Lyu · 2 weeks ago
  77. 5c855be MINOR: Remove dead code of metric forward-rate (#15686) by Bruno Cadonna · 2 weeks ago
  78. dd80a90 KAFKA-16004: auto-commit inflight improved logs, docs and tests (#15669) by Lianet Magrans · 2 weeks ago
  79. a4d6456 KAFKA-15538: Client support for java regex based subscription (#15585) by Phuc-Hong-Tran · 2 weeks ago
  80. 9a6760f KAFKA-16310 ListOffsets doesn't report the offset with maxTimestamp a… (#15621) by Chia-Ping Tsai · 2 weeks ago
  81. 983a94a KAFKA-16487 Support to define server properties by ClusterTestDefaults (#15687) by PoAn Yang · 2 weeks ago
  82. 3ad6482 KAFKA-13907 Fix hanging ServerShutdownTest.testCleanShutdownWithKRaftControllerUnavailable (#12174) by Igor Soarez · 2 weeks ago
  83. a95a40d KAFKA-16485: Broker metrics to follow kebab/hyphen case (KIP-714) (#15680) by Apoorv Mittal · 2 weeks ago
  84. f895ab5 KAFKA-16455: Check partition exists before send reassignments to server in ReassignPartitionsCommand (#15659) by Kuan-Po (Cooper) Tseng · 2 weeks ago
  85. 169ed60 KAFKA-16477 Detect thread leaked client-metrics-reaper in tests (#15668) by Kuan-Po (Cooper) Tseng · 2 weeks ago
  86. 22f9eee KAFKA-16481: Fixing flaky test kafka.server.ReplicaManagerTest#testRemoteLogReaderMetrics (#15677) by vamossagar12 · 2 weeks ago
  87. 4e0578f KAFKA-16156: beginningOrEndOffsets does not need to build an OffsetAndTimestamps object upon completion (#15525) by Philip Nee · 2 weeks ago
  88. 8e61f04 MINOR: Fix usage of none in javadoc (#15674) by Erik van Oosten · 2 weeks ago
  89. 4b2278f MINOR: Default test name added to core (#15667) by Nikolay · 3 weeks ago
  90. 31e8a7f MINOR: Default test name added to tools (#15666) by Nikolay · 3 weeks ago
  91. 6de58d2 MINOR; Missing minISR config should log a debug message (#15529) by Calvin Liu · 3 weeks ago
  92. dc189a3 MINOR: Improvements to release.py (#15651) by Manikumar Reddy · 3 weeks ago
  93. bdd8540 KAFKA-16293: Test log directory failure in Kraft (#15409) by Gaurav Narula · 3 weeks ago
  94. e798bed KAFKA-16234: Log directory failure re-creates partitions in another logdir automatically (#15335) by Omnia Ibrahim · 3 weeks ago
  95. 5c1b819 KAFKA-16472 Fix integration tests in Java with parameter name (#15663) by PoAn Yang · 3 weeks ago
  96. fd9c7d2 MINOR: Add 3.6.2 to system tests (#15665) by Manikumar Reddy · 3 weeks ago
  97. 5e4c7da KAFKA-15915: Flaky ProducerIdManagerTest error injection fix (#15605) by Andras Katona · 3 weeks ago
  98. 16019b0 MINOR: remove redundant check in appendLegacyRecord (#15638) by Johnny Hsu · 3 weeks ago
  99. a2ee085 KAFKA-16471 invoke SSLEngine::closeInbound on SslTransportLayer close (#15655) by Gaurav Narula · 3 weeks ago
  100. 862c2bf MINOR: remove redundnat list initialization (#15641) by Kuan-Po (Cooper) Tseng · 3 weeks ago