Google Git
Sign in
apache/kafka/HEAD
  1. 209a1b6 KAFKA-20328 : [1/N] headers-aware api test coverage (#22196) by Murali Basani · 3 hours ago trunk
  2. 7650785 MINOR: Updates build and project dependencies (#22939) by Dejan Stojadinović · 3 hours ago
  3. 155640c KAFKA-20648: Move Processor object and tests to server module (#22439) by Mickael Maison · 3 hours ago
  4. 9ae317d KAFKA-17840: Move QuotaFactory to server module (#22721) by Mickael Maison · 3 hours ago
  5. b706c58 KAFKA-20413: Make Streams suppress headers-aware (#22165) by Alieh Saeedi · 6 hours ago
  6. b992620 KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect (#20384) by Anton Liauchuk · 9 hours ago
  7. 17f3f8a MINOR: Cleanups following KAFKA-20637 (#22584) by Mickael Maison · 10 hours ago
  8. 58f63f4 MINOR: Complete nodeApiVersions future when describeFeatures fails (#22978) by Ming-Yen Chung · 10 hours ago
  9. 507d01d KAFKA-14648 Do not fail clients if bootstrap servers is not immediately resolvable (#21080) by TengYao Chi · 11 hours ago
  10. acca881 MINOR: Update MiniKdc class path in minikdc.py (#22976) by PoAn Yang · 12 hours ago
  11. 6fd96a3 KAFKA-20665: Bump group epoch for warm-up refinement steps (#22748) by Matthias J. Sax · 13 hours ago
  12. 20e952c KAFKA-20780: Fix to clear completed inflight poll on empty fetch response and time left (#22979) by Lianet Magrans · 16 hours ago
  13. 209ef93 MINOR: deflake AdminMetadataTest (#22968) by Nikita Shupletsov · 17 hours ago
  14. a5b7fc0 MINOR: Fix blog post link in uses.md (#22972) by Aravind Reveendran · 18 hours ago
  15. 553f663 KAFKA-20665: Promote a warm-up task to active in place in the reconciler (#22923) by Matthias J. Sax · 19 hours ago
  16. 6ce2682 KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (#22784) by Ken Huang · 22 hours ago
  17. 12e135b MINOR: Fix Javadoc code sample in KafkaShareConsumer (#22974) by Sanskar Jhajharia · 22 hours ago
  18. 0d26e55 KAFKA-20825 Fix native image startup with share group DLQ manager (#22900) by YANG-SYUAN CHOU · 26 hours ago
  19. ab61875 KAFKA-20842 Bump lz4 to 1.11.1 (#22962) by Federico Valeri · 26 hours ago
  20. ec89db2 MINOR: Align consumer assignor loading with share and streams (#22929) by Matthias J. Sax · 31 hours ago
  21. 8001408 KAFKA-20706: IQv2 TimestampedWindowRangeWithHeadersQuery (KIP-1356) (#22853) by Jess668 · 2 days ago
  22. dee0805 MINOR: add suppress() header-propagation scenario tests (#22955) by Matthias J. Sax · 2 days ago
  23. 63f445a KAFKA-20828: Derive client throttling from response schema (#22908) by Arnab Nandy · 2 days ago
  24. ab890f6 MINOR: Rewrite testListTopicsWithOptionListInternal (#22960) by TengYao Chi · 2 days ago
  25. 774e0ab MINOR: "streams" TaskAssignors must be thread-safe (#22930) by Matthias J. Sax · 2 days ago
  26. 8e365ae KAFKA-15899: [2/2] Move kafka.security package from core to server module (#21407) by Christo Lolov · 2 days ago
  27. fa9e1e4 MINOR: Fix StreamPartitioner deprecation warning in ProcessorTopology (#22944) by Yu-Chia Ma · 2 days ago
  28. 64d9aa7 MINOR: Clean up SSL support for ClusterTestExtensions (#22876) by YANG-SYUAN CHOU · 2 days ago
  29. b231920 KAFKA-20840: Bump jetty to 12.0.37 (#22956) by Federico Valeri · 2 days ago
  30. 01f50af KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException (#22073) by Mingi Cho · 2 days ago
  31. 226ce2d KAFKA-20832: Fix cordon logic with user specified assignments (#22926) by Mickael Maison · 2 days ago
  32. 6784c62 KAFKA-20809: Updated getting started docs with share group DLQ. (#22950) by Sushant Mahajan · 2 days ago
  33. 6455a7b KAFKA-19686: Trigger docker builds with rc and release in release script (#21963) by Murali Basani · 2 days ago
  34. bf49716 KAFKA-19491 CONSUMER protocol metrics documentation (#22684) by Ritikj55 · 2 days ago
  35. 205b70a KAFKA-12570: Document compact arrays in flexible versions (#22862) by Gabriel Dutra · 2 days ago
  36. ae9cf0f KAFKA-20723: Resolve DLQ copy records per produce round. (#22919) by Sushant Mahajan · 2 days ago
  37. 19815b8 KAFKA-20410: Make KIP-1191 cluster configs dynamic. (#22949) by Sushant Mahajan · 2 days ago
  38. 3978783 KAFKA-20826 Fix EndToEndLatencyTest#testInvalidRecordHeaderValue (#22909) by majialong · 2 days ago
  39. 908d496 HOTFIX: Remove Time.SYSTEM from ProducerMetadata (#22953) by PoAn Yang · 2 days ago
  40. 36a69b4 KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate (#22083) by PoAn Yang · 2 days ago
  41. a3123b0 KAFKA-967 Use key range in ProducerPerformance (#22326) by Ken Huang · 2 days ago
  42. 123356b MINOR: Scala to Java migration. Migrated some tests from PlaintextAdminIntegrationTest to a new java class. (#22290) by Nikita Shupletsov · 3 days ago
  43. a9fa6f7 KAFKA-20830 Speed up testFailToStartWhenInternalTopicsAreNotCompacted (#22931) by red-flames · 3 days ago
  44. 34e04e3 KAFKA-20412: Fix prefixScan for KV-Store with headers (#21971) by Uladzislau Blok · 3 days ago
  45. cba250e KAFKA-20197: Headers aware StreamPartitioner (#22570) by Uladzislau Blok · 3 days ago
  46. b91561a KAFKA-20744: Add back `rack.aware.assignment.tags` config (#22213) by gabriellafu · 3 days ago
  47. 3ab2c3e KAFKA-20553 Use ClusterInstance for streams ResetIntegrationTest (#22871) by Ken Huang · 3 days ago
  48. a1d9d8a KAFKA-20829: Throttle StreamThread shutdown rebalance enforcement to avoid log flood (#22917) by Adam Souquières · 4 days ago
  49. be319ea MINOR: Remove testImplementation storage:storage-api (#22924) by Ken Huang · 5 days ago
  50. 9533d78 KAFKA-20553 Prevent modules from depending on core test output (#22564) by majialong · 5 days ago
  51. f4c3454 KAFKA-20827: don't re-create an already-owned task on assignment (#22925) by Alan Lau · 5 days ago
  52. e51258d KAFKA-20790: Promote streams assignor API to public module (#22788) by gabriellafu · 5 days ago
  53. 2699fc4 KAFKA-20553 Remove clients-integration-tests dependency on core test output (#22884) by majialong · 5 days ago
  54. 9f15f3c KAFKA-20804: Reduce lock contention in ProducerMetadata#add (#22810) by Xi · 5 days ago
  55. c0579db KAFKA-20769: ListDeserializer can silently deserialize a corrupted entry when the input is truncated mid-entry (#22755) by Sepuri Sai Krishna · 5 days ago
  56. 362a037 KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit (#22006) by Mingi Cho · 6 days ago
  57. f324cb5 MINOR: Set StreamThread to non-daemon status (#22902) by Bill Bejeck · 6 days ago
  58. 805eb7b KAFKA-20723: Bound decompression memory in ShareGroupDLQRecordFetcher (#22905) by Sushant Mahajan · 6 days ago
  59. 5a01881 MINOR: Fix typo in build.gradle and dependencies.gradle (#22916) by YANG-SYUAN CHOU · 6 days ago
  60. 9f69264 KAFKA-20553 Remove tools module dependency on core test output (#22899) by majialong · 6 days ago
  61. c300006 KAFKA-20695: Extend "describe group" to return "task offset" metadata (#22808) by gabriellafu · 7 days ago
  62. 13f5dd3 MINOR: Cleanup build.gradle unused dependency (#22903) by Ken Huang · 7 days ago
  63. 3c25746 MINOR: Fix KStream leftJoin doc and test param naming for KStream-GlobalKTable (#22889) by Lucy Liu · 7 days ago
  64. 3d48cb3 KAFKA-19871: Update test with new TopologyTestDriverBuilder (#22892) by Sebastien Viale · 7 days ago
  65. e9eef52 MINOR: bump jline to 3.30.16 (#22906) by Gergely Harmadas · 7 days ago
  66. 0ed2ce8 MINOR: Reduce DescribeStreamsGroupTest execution time (#22885) by YANG-SYUAN CHOU · 7 days ago
  67. df0392f KAFKA-20815: Remove unnecessary jline deps and bump to latest 3.x (#22898) by Gergely Harmadas · 7 days ago
  68. cb2f143 KAFKA-20673 Skip stale-leader lookup retry while the AdminClient is closing (follow-up) (#22529) by Lucas Brutschy · 7 days ago
  69. ebac341 KAFKA-20278 : streams - Refactor setup pattern, PART-1 (#21754) by Murali Basani · 8 days ago
  70. 974afa2 KAFKA-19584 add SecurityManager shim support to native image (#22379) by Gaurav Narula · 8 days ago
  71. 8fc539c KAFKA-20783: Minor change to include try/finally block for locks release (#22891) by Apoorv Mittal · 8 days ago
  72. b68bb0d MINOR: increase build timeout to 3.5 hours (#22887) by Matthias J. Sax · 8 days ago
  73. eac5d57 KAFKA-20553 Remove storage dependency on core test output (#22854) by YANG-SYUAN CHOU · 8 days ago
  74. 01ba1b2 MINOR: Fix RandomAccessFile leak in FileRecords.openChannel (#22878) by David Simon · 8 days ago
  75. 524ef3b MINOR: Narrow remote copy lag validator props to Map<String, ?> and update the upgrade doc for KIP-1241 (#22363) by Jian · 8 days ago
  76. cb69d57 MINOR: Rewrite TransactionMetadataTest from Scala to Java (#22811) by Ken Huang · 9 days ago
  77. 45443a6 KAFKA-20783: Fixes for locks release for async handling in DelayedShareFetch (6/N) (#22881) by Apoorv Mittal · 9 days ago
  78. 8f48a25 KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins (#22807) by Lucy Liu · 9 days ago
  79. 33ea66b KAFKA-20736: Improve share session handling on leader change (#22766) by Andrew Schofield · 9 days ago
  80. 260a397 MINOR: Remove redundant bcpkix test dependency from tools module (#22868) by red-flames · 10 days ago
  81. 8c695ce KAFKA-20553 Use ClusterInstance for streams group command tests (#22701) by PoAn Yang · 10 days ago
  82. fdc59be KAFKA-18448 SSL support for ClusterTestExtensions (#22184) by Igor Soarez · 10 days ago
  83. a47f8ce MINOR: Move JaasModule into JaasUtils (#22867) by YANG-SYUAN CHOU · 10 days ago
  84. d366f75 MINOR: Rewrite SaslClientsWithInvalidCredentialsTest and rename to ConsumerGroupCommandSaslAuthenticationTest (#22582) by majialong · 11 days ago
  85. 0e08d48 KAFKA-20772 (3/3): Add ducktape system tests for share group DLQ with tiered storage (#22858) by Sanskar Jhajharia · 11 days ago
  86. 8301882 MINOR: Correct configuration property names in the Kafka Connect ACL tables (#22847) by yangxuze · 11 days ago
  87. 678c0e0 MINOR: Kafka Streams should log broker provided KIP-1071 config values (#22730) by Matthias J. Sax · 12 days ago
  88. edc0800 KAFKA-20808: StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException (#22855) by Matthias J. Sax · 12 days ago
  89. 05cbe68 KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine (#22678) by Zhiyan Tang · 12 days ago
  90. 7e368e8 KAFKA-20772 (2/n): Add multi-partition and multi-topic DLQ system tests (#22851) by Sanskar Jhajharia · 12 days ago
  91. 3408aa3 KAFKA-20538: Make RocksDBTimeOrderedKeyValueBuffer headers-aware (#22166) by Alieh Saeedi · 13 days ago
  92. 2345482 KAFKA-18951 Correct topic name in client example docs (#22812) by Gabriel Dutra · 13 days ago
  93. 2f04be7 MINOR: Updated log reader interface to abstractions (#22841) by Apoorv Mittal · 13 days ago
  94. 23927a2 MINOR: Fix broken relative links in docs/ (#22813) by Ming-Yen Chung · 13 days ago
  95. 5b6a94b MINOR: Replace deprecated TopologyTestDriver constructor in TestTopicsTest (#22782) by Jiayáo Sun · 13 days ago
  96. d9c4e22 MINOR: fix flakey SwallowUnknownTopicErrorIntegrationTest (#22845) by Matthias J. Sax · 13 days ago
  97. b30cd5f KAFKA-20760: Break out PositionRestartIntegrationTest into sub-class for transactional stores (#22823) by Bill Bejeck · 13 days ago
  98. bd5fcec MINOR: Fix DLQ records using a non-epoch clock for their timestamp (#22849) by Sanskar Jhajharia · 13 days ago
  99. 931fde9 KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios (#22786) by Sanskar Jhajharia · 13 days ago
  100. 3b849ff KAFKA-19663 Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers (#20598) by TaiJuWu · 13 days ago