Google Git
Sign in
apache/kafka/HEAD
  1. 22c1e44 MINOR: Include numeric bound in group config validation errors (#22185) by David Jacot · 51 minutes ago trunk
  2. 474798a KAFKA-20072: Don't generate IDs with hyphens (#21313) by Dmitry Werner · 3 hours ago
  3. 4bb8f0f MINOR: Fix duplicate args in KStreamSessionWindowAggregateProcessorTest (#22183) by Alieh Saeedi · 12 hours ago
  4. 5645518 KAFKA-20542 : Fix aggregatedJavadocs build failure (#22172) by Murali Basani · 21 hours ago
  5. cb7e3ab KAFKA-20410: Register topic DLQ configs in LogConfig. [2/N] (#22167) by Sushant Mahajan · 24 hours ago
  6. 8a1c198 KAFKA-20366: Add syntax highlighting in security docs (#21965) by gomudayya · 25 hours ago
  7. faa8b48 KAFKA-20533: Correcting error response for topic deletion during share fetch (#22170) by Apoorv Mittal · 2 days ago
  8. 07e0cae KAFKA-18652: Add `num.warmup.replicas` config (#21801) by Matthias J. Sax · 2 days ago
  9. e6653a9 MINOR: Fix Javadoc for ConfigCommand.java (#22101) by Atharv Chavan · 2 days ago
  10. a310bcb MINOR: system-tests: fix KafkaServer#leader (#22168) by Gaurav Narula · 2 days ago
  11. ebd7cd3 MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide (#22067) by Lucas Brutschy · 2 days ago
  12. f47b9a4 KAFKA-20362 Resolve reviewer email via GitHub commit search API (#22135) by Ming-Yen Chung · 2 days ago
  13. d02723a MINOR: Add shutdown broker and bootstrap controller for ConfigCommand (#22134) by Ken Huang · 2 days ago
  14. 82d0c12 MINOR: Add topicId parameter to OffsetAndMetadata.fromRequest for TxnOffsetCommit (#22159) by David Jacot · 2 days ago
  15. 7340eef MINOR: Reshape TxnOffsetCommitRequest.Builder (#22147) by David Jacot · 2 days ago
  16. 20c2450 MINOR: Reshape TxnOffsetCommitResponse.Builder (#22146) by David Jacot · 2 days ago
  17. 2dfdb70 MINOR: Fix typo in testConsumerGroupHeartbeatRebalance (#22119) by Sean Quah · 2 days ago
  18. c75e10d KAFKA-20424 : clients: Update KafkaConsumerTest comments,tests with relevant protocol (#22144) by Murali Basani · 2 days ago
  19. 90a4c93 MINOR: Fix testRackAwareAssignment flake (#22154) by Sean Quah · 2 days ago
  20. 44bafc6 KAFKA-20426 Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer (#22018) by Kuan-Po Tseng · 2 days ago
  21. 8afeecc MINOR: Add streams group tests to GroupCoordinatorIntegrationTest (#21772) by Lucas Brutschy · 2 days ago
  22. ddec811 KAFKA-19937: Introduced Shared ReaperThread for Persister / NetworkPartitionMetadataClient (#21842) by Rion Williams · 2 days ago
  23. eef6cab KAFKA-20450 Allowlist based SafeObjectInputStream (#22056) by subbudvk · 2 days ago
  24. 3c9b210 KAFKA-20456: Avoid persisting closed state if store is not open yet (#22140) by Eduwer Camacaro · 3 days ago
  25. d0e0ec4 KAFKA-20312: Handle null leader during OffsetFetcher regroup safely (#21760) by nileshkumar3 · 3 days ago
  26. 76dcd5f MINOR: Reduce duplicate parameter combinations in heavy Streams integration tests (#22125) by Alieh Saeedi · 3 days ago
  27. 0dad6a7 KAFKA-20512 : Fix flakiness - same output topic is being used for all parameterized tests (#22112) by Murali Basani · 6 days ago
  28. 150f09f KAFKA-20519 Fix broken links in configuration option docs (#22127) by Jakub Scholz · 7 days ago
  29. 1938d32 MINOR: Removed `setMetadataLogDirectory` unused method (#22128) by Paolo Patierno · 7 days ago
  30. c946802 KAFKA-20506 kafka-configs.sh can't delete the config from a offline broker when using bootstrap controller (#22104) by Ken Huang · 7 days ago
  31. e1cfea3 KAFKA-20505: Moving future completion out of locks for Share Partition (#22126) by Apoorv Mittal · 7 days ago
  32. 0d95e46 MINOR: Remove unnecessary min.assignment.interval.ms config from test (#22120) by Sean Quah · 7 days ago
  33. 3e32d9a MINOR: add missing javadoc to Metadata.java (#22106) by Ivan Malutin · 8 days ago
  34. 28402a3 MINOR: Move CreateTopicsRequestTest to clients-integration-tests and rewrite in Java (#22105) by majialong · 8 days ago
  35. 7b5d4ca KAFKA-20362 Fall back to GitHub handle when reviewer email is unavailable (#22108) by Ming-Yen Chung · 8 days ago
  36. a3f1732 KAFKA-19193 Support rack-aware partitioning for Kafka producer (#19850) by Ivan Yurchenko · 8 days ago
  37. 63cc2f3 KAFKA-18149: Docs improvement for dynamic kraft quorum (#18350) by PoAn Yang · 8 days ago
  38. 30cea6f KAFKA-20456: Use lighter options for RocksDB offsets column family (#22085) by Bill Bejeck · 9 days ago
  39. 0a367aa KAFKA-20297 Move OperatingSystem, Java, Exit... into internal (#22093) by Ken Huang · 9 days ago
  40. 4766b29 MINOR: Fix typos in UnifiedLog and LocalLog exception messages (#22107) by Jiayao Sun · 9 days ago
  41. dc5f816 KAFKA-9914: Fix replication cycle detection (#22079) by Tommi Vainikainen · 9 days ago
  42. b6d2503 KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) (#21979) by Sanskar Jhajharia · 9 days ago
  43. 75052bb KAFKA-20422: Add DSL integration tests for header stores with explicit suppliers (#22002) by Alieh Saeedi · 10 days ago
  44. 282eef9 MINOR: Add DCL to improve performance (#22098) by Bolin Lin · 10 days ago
  45. f1f0d97 MINOR: remove un-necessary integration tags (#22095) by Maros Orsak · 10 days ago
  46. 3b80855 MINOR: version updates for build and test dependencies (#21651) by Dejan Stojadinović · 10 days ago
  47. 8ae35c0 MINOR: add DCL on get or create meter for performance improvement (#22084) by Bolin Lin · 12 days ago
  48. 4ae78a3 KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal (#22081) by Ken Huang · 12 days ago
  49. a09f7eda MINOR: Bump setup-qemu-action, setup-buildx-action, and login-action (#22090) by PoAn Yang · 12 days ago
  50. 46773ce KAFKA-14588 Move ConfigCommand to tools module (#22013) by Mickael Maison · 12 days ago
  51. 0749b32 MINOR: Fix ListValueStore's restoration in headers mode (#22068) by Alieh Saeedi · 13 days ago
  52. 963bc6a KAFKA-20373: Bump maven artifact to 3.9.15 (#21911) by averemee-si · 13 days ago
  53. 4d0a85f KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests (#21999) by Bill Bejeck · 13 days ago
  54. 78fd214 MINOR: formatting fix on UpdateRaftVoterRequest class declaration (#22010) by Paolo Patierno · 14 days ago
  55. e7a5688 KAFKA-20297 move Crc32C Checksums and Sanitizer from utils to utils.internals (#22072) by Chia-Yi Chiu · 2 weeks ago
  56. 2791424 MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test classes (#22057) by Ken Huang · 2 weeks ago
  57. f95a1f9 MINOR: increase test visibility to public in client integration tests. (#22069) by Nikita Shupletsov · 2 weeks ago
  58. 07a6da3 MINOR: Split up ShareConsumerTest (#22017) by Andrew Schofield · 2 weeks ago
  59. 3852c50 MINOR: add comma before "and" in README (#22064) by Chia-Yi Chiu · 2 weeks ago
  60. 2299a06 KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal (#22052) by Ken Huang · 2 weeks ago
  61. e08a150 KAFKA-20442: Update streams group assignment epoch when last member leaves (#22047) by David Jacot · 2 weeks ago
  62. 56be355 KAFKA-20442: Update share group assignment epoch when last member leaves (#22046) by David Jacot · 2 weeks ago
  63. 5268721 KAFKA-20442: Update consumer group assignment epoch when last member leaves (#22045) by David Jacot · 2 weeks ago
  64. 45c4bdc MINOR: Clarify docs for consumer leave options & rebalances (#22058) by Lianet Magrans · 2 weeks ago
  65. 7f9f34a KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… (#22038) by Abhijeet Kumar · 2 weeks ago
  66. a39e714 KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG (#22055) by Tamas Kornai · 2 weeks ago
  67. b4c9775 KAFKA-20297 move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal (#22049) by Chia-Yi Chiu · 2 weeks ago
  68. 972f32d KAFKA-19768 Update ci-complete to support branch 4.0 buildscan upload (#20805) by Ming-Yen Chung · 2 weeks ago
  69. c4823da KAFKA-20165 [2]: Integration tests to validate different OffsetFetch response behaviour on topic deleted (#21509) by Lianet Magrans · 2 weeks ago
  70. 676712f MINOR: Delegate version updates to Gradle in release script (#22031) by PoAn Yang · 2 weeks ago
  71. 571cf30 MINOR: fix incorrect JavaDocs for headers-stores (#22043) by Matthias J. Sax · 2 weeks ago
  72. 402cb65 Revert "KAFKA-13499: Avoid restoring outdated records (#21901)" by Matthias J. Sax · 2 weeks ago
  73. f9d502b MINOR: Clarify group.consumer.assignors doc about default assignor change (#22039) by David Jacot · 2 weeks ago
  74. 23bce3d KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 (#22053) by PoAn Yang · 2 weeks ago
  75. e2b5eb6 KAFKA-20329: Test headers dsl.store.format further (4/N) (#21827) by Alieh Saeedi · 2 weeks ago
  76. 6c651fb KAFKA-20329: Test headers dsl.store.format further (3/N) (#21820) by Alieh Saeedi · 2 weeks ago
  77. 6278e10 KAFKA-20252: Migrate clearYammerMetrics to TestUtils (#21679) by Kartikay Dubey · 2 weeks ago
  78. f8aa614 MINOR: Clarify components not considered for security issues (#22048) by Mickael Maison · 2 weeks ago
  79. 37b1a07 MINOR: Move KafkaMetricsGroupTest from Scala to Java (#22028) by Ken Huang · 2 weeks ago
  80. 40de3a6 MINOR: Bump pytest from 8.3.3 to 9.0.3 in /tests (#22042) by dependabot[bot] · 2 weeks ago
  81. 2327e51 KAFKA-20182 Remove removeUnusedImports and upgrade spotless to 8.4.0 (#22025) by Ming-Yen Chung · 2 weeks ago
  82. 4acdac6 MINOR: Flaky test fixes (#21986) by Andrew Schofield · 2 weeks ago
  83. 0d9fe51 KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor (#22036) by David Jacot · 2 weeks ago
  84. e30f771 MINOR: Code cleanup in server module (#22026) by nileshkumar3 · 2 weeks ago
  85. acd37fc MINOR: Fix arguments in trivy scan (#22032) by PoAn Yang · 3 weeks ago
  86. eb6ce0e MINOR: Change trivy action (#22024) by PoAn Yang · 3 weeks ago
  87. 4b9eddc KAFKA-20428: Fix unsubscribe failure with assignment updates (#22011) by Lianet Magrans · 3 weeks ago
  88. a332a84 MINOR: Various code cleanups in server (#22021) by Mickael Maison · 3 weeks ago
  89. 1980f38 MINOR: Fix tool package in kafka-dump-log.bat (#22014) by Mickael Maison · 3 weeks ago
  90. 2fd5946 MINOR: fix the Custom Exception Handler Implementation example. (#22022) by Nikita Shupletsov · 3 weeks ago
  91. 6c0778a KAFKA-20245: DLQ share group client REJECT ack records. [2/N] (#21793) by Sushant Mahajan · 3 weeks ago
  92. 917caae KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests (#21998) by Bill Bejeck · 3 weeks ago
  93. d5d9868 KAFKA-20431: ConsumerGroupDescribe API does not return partitions being revoked (#22015) by David Jacot · 3 weeks ago
  94. ec17e5a KAFKA-20378 Make container memory limit configurable (#21924) by Maros Orsak · 3 weeks ago
  95. 30edb58 KAFKA-20323: Refactor deleteRecords stub to use partition-based matching for Mockito upgrade (#21857) by Mingi Cho · 3 weeks ago
  96. c0e77d1 KAFKA-19914: Move AlterPartitionManager to server module (#21432) by Chih-Yuan Chien · 3 weeks ago
  97. a0446e3 KAFKA-20363 Fix flaky testIdleTimeCallback in KafkaEventQueueTest (#21920) by Murali Basani · 3 weeks ago
  98. be6feb2 KAFKA-20354: Add missing Control Batch types in documentation (#21866) by Federico Valeri · 3 weeks ago
  99. 7aaf4de KAFKA-20182 Upgrade gradle to 9.4.1 and spotless to 8.3.0 (#22012) by Ming-Yen Chung · 3 weeks ago
  100. 123ee9e KAFKA-20393: Fix stickyNode using stale IP when broker address changes (#21983) by Daeho Kwon · 3 weeks ago