Google Git
Sign in
apache / kafka / HEAD
  1. b72db2b MINOR: Delete temporary directories after using them in RaftManagerTest Updated (#20550) by Ryan Dielhenn · 6 hours ago trunk
  2. 5ed4a48 MINOR: Tighten up argument descriptions for console CLI tools (#20554) by Andrew Schofield · 7 hours ago
  3. dbd2b52 MINOR: Fix format in CoordinatorLoaderImplTest (#20548) by Sean Quah · 19 hours ago
  4. 8c8e93c MINOR: Remove metrics attribute from ConsumerGroup (#20542) by David Jacot · 24 hours ago
  5. d6fdbfc MINOR: Fix typos in CoordinatorRecordTypeGenerator (#20549) by David Jacot · 24 hours ago
  6. 04b4a8f KAFKA-19705: Enable streams rebalance protocol in IQv2 integration test (#20541) by Jinhe Zhang · 25 hours ago
  7. e647bdc MINOR : Fix parantheses in console_consumer.py and console_share_consumer.py (#20552) by Shivsundar R · 26 hours ago
  8. 9a32a71 KAFKA-19699 improve the documentation of `RecordsToDelete` (#20527) by Lan Ding · 2 days ago
  9. 3bc50f9 KAFKA-19623: Implement KIP-1147 for console producer/consumer/share-consumer. (#20479) by Shivsundar R · 2 days ago
  10. bbbc0cf MINOR: Fix format in CoordinatorLoaderImpl (#20538) by David Jacot · 2 days ago
  11. 8ba41a2 MINOR: Expose internal topic creation errors to the user (#20325) by Jinhe Zhang · 3 days ago
  12. b043ca2 KAFKA-19683: Remove dead tests and modify tests in TaskManagerTest [1/N] (#20501) by Shashank · 3 days ago
  13. 9f657ab MINOR: Improve consumer rebalance callbacks docs (#20528) by Lianet Magrans · 3 days ago
  14. 2c34738 KAFKA-19694: Trigger StreamsRebalanceListener in Consumer.close (#20511) by Lucas Brutschy · 3 days ago
  15. daa7aae KAFKA-19604 Document controller.quorum.auto.join.enable config in upgrade.html (#20409) by Lan Ding · 3 days ago
  16. dddb619 MINOR: Move RaftManager interface to raft module (#20366) by Jhen-Yung Hsu · 3 days ago
  17. 3cbb2a0 MINOR: Small cleanups in clients (#20530) by Mickael Maison · 4 days ago
  18. caeca09 MINOR: Improve producer docs and add tests around timeout behaviour on missing topic/partition (#20533) by Lianet Magrans · 4 days ago
  19. 3fcc0c2 MINOR: Fix an off-by-one issue in ValuesTest (#20520) by Alex · 4 days ago
  20. 8628d74 KAFKA-19661 [6/N]: Use heaps also on the process-level (#20523) by Lucas Brutschy · 4 days ago
  21. 749c2d9 KAFKA-19609 Move TransactionLogTest to transaction-coordinator module (#20460) by Hong-Yi Chen · 4 days ago
  22. e1b7699 MINOR: Bump versions in CI (#20497) by Yunchi Pang · 4 days ago
  23. 2fd54837f MINOR: Update on fixing tag description missing in javadoc (#20380) by keemsisi · 4 days ago
  24. a9e5292 MINOR: increase Config change throwable log info to error (#14380) by NICOLAS GUYOMAR · 4 days ago
  25. 374bc46 MINOR: Cleanups in ops docs (#20532) by Mickael Maison · 5 days ago
  26. 962f4ad KAFKA-19203 Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient (#19623) by Chang-Chi Hsu · 5 days ago
  27. 026710c MINOR: Update ClusterTestExtensions Javadoc example (#20525) by Logan Zhu · 6 days ago
  28. af2a8db KAFKA-18105 Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders (#20068) by Chang-Chi Hsu · 6 days ago
  29. 54b88f6 MINOR: Refactor on FeaturesPublisher and ScramPublisher (#20522) by Maros Orsak · 6 days ago
  30. 2026833 MINOR: Deflake and improve SmokeTestDriverIntegrationTest (#20509) by Lucas Brutschy · 7 days ago
  31. dd824a2 KAFKA-19666: Remove old restoration codepath from RestoreIntegrationTest [4/N] (#20498) by Shashank · 8 days ago
  32. 8a79ea2 KAFKA-19676 EpochState should override close to avoid throwing IOException (#20508) by jimmy · 8 days ago
  33. 865beb6 MINOR: Remove explicit version list from upgrade.from docs (#20518) by Mickael Maison · 9 days ago
  34. ff5025a KAFKA-19695: Fix bug in redundant offset calculation. (#20516) by Sushant Mahajan · 9 days ago
  35. 3512038 KAFKA-19661 [5/N]: Use below-quota as a condition for standby task assignment (#20458) by Lucas Brutschy · 9 days ago
  36. 709c5fa KAFKA-19666: Remove old restoration codepath from EosIntegrationTest [5/N] (#20499) by Shashank · 9 days ago
  37. a244565 KAFKA-18708: Move ScramPublisher to metadata module (#20468) by Maros Orsak · 9 days ago
  38. 32b8e32 MINOR: Add 4.1.0 to streams system tests (#20480) by Mickael Maison · 9 days ago
  39. 1ea221c MINOR: Add 4.1.0 to core system tests (#20477) by Mickael Maison · 9 days ago
  40. 675552a KAFKA-19490: Remove usages of distutils in docker scripts (#20178) by PoAn Yang · 9 days ago
  41. 8015c87 KAFKA-19679: Fix NoSuchElementException in oldest open iterator metric (#20512) by Nikita Shupletsov · 9 days ago
  42. 8065d5c MINOR: Making sure log appender is closed in ShareConsumerImplTest.java::testFailConstructor (#20514) by Genseric Ghiro · 9 days ago
  43. 45b96cb MINOR: add the explanation of `null` for DeleteAclsRequest#ResourceNameFilter (#20502) by Lan Ding · 9 days ago
  44. 0bc2c6e MINOR: Move topic creation before consumer creation in testListGroups integration test (#20496) by lucliu1108 · 9 days ago
  45. 9351270 MINOR: Add 4.1.0 to system tests (#20476) by Mickael Maison · 10 days ago
  46. d5e624e KAFKA-19693: Added PersisterBatch record in Share Partition which includes updatedState and stateBatch (#20507) by Chirag Wadhwa · 10 days ago
  47. 620a01b KAFKA-19661 [4/N]: Prefer range-style assignment (#20486) by Lucas Brutschy · 10 days ago
  48. f6f5b4c KAFKA-19565: Integration test for Streams-related Admin APIs [2/N] (#20266) by lucliu1108 · 10 days ago
  49. 9c9f144 KAFKA-18061 AddRaftVoter responds with error message "NONE" instead of null (#17930) by Linsiyuan9 · 10 days ago
  50. 1debe64 MINOR: Rename RecordSnapshotWriter.Builder.setMaxBatchSize to setMaxBatchSizeBytes (#20446) by Jonah Hooper · 10 days ago
  51. 639492c KAFKA-15307: Kafka Streams configuration docs outdated (#20408) by Shashank · 10 days ago
  52. aa3a64e KAFKA-19668: update upgrade docs (#20484) by Matthias J. Sax · 11 days ago
  53. 872647f KAFKA-19585: Avoid noisy NPE logs when closing consumer after constructor failures (#20491) by Genseric Ghiro · 11 days ago
  54. f7593db KAFKA-19666: Remove old restoration codepath from SmokeTestDriverIntegrationTest [3/N] (#20465) by Shashank · 11 days ago
  55. b3eed51 KAFKA-19660: JoinWithIncompleteMetadataIntegrationTest fails in isolated run of one parameter (#20483) by Jinhe Zhang · 11 days ago
  56. 24ea7e0 KAFKA-19666: Remove old restoration codepath from PauseResumeIntegrationTest [2/N] (#20463) by Shashank · 11 days ago
  57. 3c7f99a MINOR: Cleanup Server Module (#20180) by Sanskar Jhajharia · 11 days ago
  58. d6688f8 KAFKA-15983 Kafka-acls should return authorization already done if repeating work is issued (#20482) by Chang-Yu Huang · 12 days ago
  59. 350577d MINOR: Add doc for external schemas in JSONConverter (#20429) by jimmy · 13 days ago
  60. f6f6172 MINOR: update gradle from 8.14.1 to 8.14.3 (#20495) by Chang-Chi Hsu · 13 days ago
  61. 655cfaa MINOR: remove System.out in test (#20494) by Matthias J. Sax · 13 days ago
  62. 52dfe1e MINOR: Cleanup Raft Module (#20348) by Sanskar Jhajharia · 13 days ago
  63. 5e2f54e MINOR: Cleanup Connect Module (5/n) (#20393) by Sanskar Jhajharia · 13 days ago
  64. 9ba7dd6 KAFKA-19668: processValue() must be declared as value-changing operation (#20470) by Matthias J. Sax · 13 days ago
  65. 0a12eaa KAFKA-19112 Unifying LIST-Type Configuration Validation and Default Values (#20334) by Ken Huang · 14 days ago
  66. 548fb18 MINOR: Fix typo for the headers.separator cli option (#20489) by Levani Kokhreidze · 14 days ago
  67. 5fefb16 MINOR: extend consumer close java doc with error handling behaviour (#20472) by Lianet Magrans · 14 days ago
  68. af03353 KAFKA-19659: Wrong generic type for UnregisterBrokerOptions (#20490) by Kuan-Po Tseng · 14 days ago
  69. 29ce961 MINOR; Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" (#20371) by Jonah Hooper · 14 days ago
  70. f922ff6 KAFKA-19259: Async consumer fetch intermittent delays on console consumer (#19980) by Kirk True · 14 days ago
  71. b92d47d MINOR: Update Kafka Streams API broker compatibility table for 4.1 (#20423) by Jim Galasyn · 2 weeks ago
  72. 32c2383 KAFKA-19658 Tweak org.apache.kafka.clients.consumer.OffsetAndMetadata (#20451) by Lan Ding · 2 weeks ago
  73. 8076702 MINOR: Add Unit test for `TimingWheel` (#20443) by Ken Huang · 2 weeks ago
  74. d68c41d KAFKA-19666: Clean up integration tests related to state-updater (#20462) by Shashank · 2 weeks ago
  75. 37e04ec KAFKA-19662: Allow resetting offset for unsubscribed topic in kafka-share-groups.sh (#20453) by Andrew Schofield · 2 weeks ago
  76. 1d0c5f2 KAFKA-19667: Close ShareConsumer in ShareConsumerPerformance after metrics displayed (#20467) by Andrew Schofield · 2 weeks ago
  77. 9257c43 MINOR: Fix failed e2e compatibility_test_new_broker_test and upgrade_test.py (#20471) by jimmy · 2 weeks ago
  78. 6a1cdf8 MINOR: Refactor CLI tools to use CommandLineUtils#maybePrintHelpOrVersion (#20469) by Hong-Yi Chen · 2 weeks ago
  79. 29b940b MINOR: Use drainEvents() in ShareConsumerImpl::processBackgroundEvents (#20474) by Shivsundar R · 2 weeks ago
  80. a81f08d KAFKA-19550: Integration test for Streams-related Admin APIs [1/N] (#20244) by lucliu1108 · 2 weeks ago
  81. 6097b33 MINOR: Update supported image tags in docker_scan (#20459) by Mickael Maison · 2 weeks ago
  82. c3af206 MINOR: code cleanup (#20455) by Matthias J. Sax · 2 weeks ago
  83. ea5b5fe KAFKA-19432 Add an ERROR log message if broker.heartbeat.interval.ms is too large (#20046) by PoAn Yang · 2 weeks ago
  84. a9bce06 KAFKA-19535 add integration tests for DescribeProducersOptions#brokerId (#20420) by Hong-Yi Chen · 2 weeks ago
  85. ef10a52 KAFKA-19011 Improve EndToEndLatency Tool with argument parser and message key/header support (#20301) by Nick Guo · 2 weeks ago
  86. 6247fd9 KAFKA-19478 [3/N]: Use heaps to discover the least loaded process (#20172) by Lucas Brutschy · 2 weeks ago
  87. 4b9075b5 KAFKA-19653: Improve metavariable names in usage messages (#20438) by Andrew Schofield · 2 weeks ago
  88. d226b43 KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics (#20283) by Shivsundar R · 2 weeks ago
  89. 8448c28 MINOR: Bump requests from 2.31.0 to 2.32.4 in /tests (#19940) by dependabot[bot] · 2 weeks ago
  90. dd52058 MINOR: Cleanups in Connect (#20077) by Mickael Maison · 2 weeks ago
  91. 4271fd8 KAFKA-19564: Close Consumer in ConsumerPerformance only after metrics displayed (#20267) by Kirk True · 2 weeks ago
  92. 2ba30cc KAFKA-19574: Improve producer and consumer config files (#20302) by Federico Valeri · 2 weeks ago
  93. 342a8e6 MINOR: suppress build warning (#20424) by Matthias J. Sax · 3 weeks ago
  94. 4f2114a KAFKA-19645 add a lower bound to num.replica.fetchers (#20414) by Lan Ding · 3 weeks ago
  95. 5441f5e KAFKA-19616 Add compression type and level support to LogCompactionTester (#20396) by Yunchi Pang · 3 weeks ago
  96. e389484 MINOR: Prepend steams to group configs specific to Kafka Streams groups (#20448) by Bill Bejeck · 3 weeks ago
  97. 26fea78 MINOR: Remove default config in creating internal stream topic (#20421) by Kuan-Po Tseng · 3 weeks ago
  98. 65f789f KAFKA-19626: KIP-1147 Consistency of command-line arguments for remaining CLI tools (#20431) by Jhen-Yung Hsu · 3 weeks ago
  99. 2dd2db7 KAFKA-8350 Fix stack overflow when batch size is larger than cluster max.message.byte (#20358) by knoxy5467 · 3 weeks ago
  100. c7154b8 MINOR: improve RLMQuotaMetricsTest (#20425) by Matthias J. Sax · 3 weeks ago