Google Git Google Git
Sign in
apache/kafka/HEAD
  1. 62dca4d MINOR: Add state batch validation to ShareCoordinatorShard (#24163) by Aashish Kumar · 9 hours ago trunk
  2. 98d8eab MINOR: Update Docker log4j2 env var docs to match KafkaDockerWrapper (#23950) by Murali Basani · 9 hours ago
  3. 7f81cdf KAFKA-20731: transitToUpdateStandby is called without checking ACTIVE_RESTORING (#22864) by Arnab Nandy · 15 hours ago
  4. 5c73b87 KAFKA-21458, KAFKA-21431: Update target assignment on classic heartbeats to consumer groups (#24108) by Sean Quah · 18 hours ago
  5. 146cf78 KAFKA-21372: Build the PartitionGroup#readyToProcess log message lazily (#23985) by Ridwan · 18 hours ago
  6. 151dea7 MINOR: Cover copartition enforcement with fixed repartition topics end to end (#24148) by Lucas Brutschy · 22 hours ago
  7. 70aee9e MINOR: Add additional validation to ScramSaslClient (#24159) by Aashish Kumar · 25 hours ago
  8. cfcdfb7 MINOR: Fix log and exception messages in the coordinator runtime (#24161) by David Jacot · 27 hours ago
  9. e5f4ccc MINOR: Remove the always-false null check in CoordinatorRuntime.activeCoordinators (#24160) by David Jacot · 27 hours ago
  10. f41267a KAFKA-20684 [5/N]: Migrate Streams to RebalanceListener (#23106) by Aditya Kousik · 29 hours ago
  11. 5a3b9b3 KAFKA-21230: Build RocksDB WriteBatch at commit (#23999) by Nick Telford · 2 days ago
  12. 3f7aa8b MINOR: Add 4.3.2 to system test (#24152) by Ken Huang · 2 days ago
  13. 72bbbc3 MINOR: Remove unused share group client code (#24142) by Taewoong Kim · 2 days ago
  14. 8840091 MINOR: Partition state gauges drift when onLoaded fails (#24151) by David Jacot · 2 days ago
  15. 0d8f995 KAFKA-21033: Back off once per round when creating Streams internal topics (#23363) by Steven Schlansker · 2 days ago
  16. 5630099 MINOR: Skip cancelled tasks in MockCoordinatorExecutor (#24140) by Sean Quah · 2 days ago
  17. 3ad111c MINOR: Fix units of the default Streams integration test startup timeout (#24149) by Lucas Brutschy · 2 days ago
  18. edd43b4 MINOR: Fix the unknown record type warning in CoordinatorLoaderImpl (#24143) by David Jacot · 2 days ago
  19. 5814362 MINOR: Check the argument in member setSubscribedTopicNames (#24058) by David Jacot · 2 days ago
  20. f008ee8 MINOR: Fix Javadoc in coordinator-common (#24144) by David Jacot · 2 days ago
  21. 6cb11d9 MINOR: Initializing share group state fails after the share group is deleted (#24106) by David Jacot · 2 days ago
  22. 3eb8b73 MINOR: Failed share group heartbeat leaves the new member in the group (#24128) by David Jacot · 2 days ago
  23. 8e75faf KAFKA-21302: Sort copartition groups and indexes for consistent Streams topology comparison (#23855) by ChickenchickenLove · 2 days ago
  24. 7057038 MINOR: Copartitioning check uses the fixed repartition topics of the whole topology (#24127) by David Jacot · 2 days ago
  25. 8f4cc1d MINOR: Move inter-broker NetworkClient factory to server module (#22346) by Jiayáo Sun · 3 days ago
  26. 38faa94 KAFKA-20554 Document acks=1 record loss during planned leader transitions (#22233) by Julian Bergner · 3 days ago
  27. af6896f MINOR: Fix vacuous assertions in DescribeTopicPartitionsRequestHandlerTest (#24117) by jujonghun · 3 days ago
  28. 446b071 MINOR: Acquire the context lock before the try block in the runtime helpers (#24130) by David Jacot · 3 days ago
  29. a4c94df MINOR: add cluster-mirroring label for pull requests (#24125) by Gaurav Narula · 3 days ago
  30. 91b9133 MINOR: Add missing @Override annotations in clients (#24076) by Ankit Sharma · 3 days ago
  31. 1e8a59f KAFKA-20118 Improve the error message caused by normally moving replica (#21470) by Parker Chang · 3 days ago
  32. 094fbfd KAFKA-20834: Add toString test coverage for Bytes (#22922) by 이주호 · 3 days ago
  33. ef6a6c1 MINOR: Avoid a double map lookup in TopologyMetadata (#24045) by David Jacot · 5 days ago
  34. fa50073 MINOR: Remove test-only methods from ProcessState (#24042) by David Jacot · 5 days ago
  35. b8b2e6b MINOR: Avoid double map lookups in GroupMetadataManager (#24126) by David Jacot · 5 days ago
  36. 623ec1a KAFKA-20292: Avoid copying share group assignable partitions in GroupSpecBuilder (#23896) by Sean Quah · 5 days ago
  37. b26fccf KAFKA-21422: Isolate per entry failures in TransactionMarkerRequestCompletionHandler (#24114) by Dongnuo Lyu · 5 days ago
  38. 9052057 MINOR: Use orElseGet for the topology fallback in StreamsGroup describe (#24081) by David Jacot · 5 days ago
  39. 09f2dc1 MINOR: Suppress deprecation and removal warnings in AdminClientTimeoutIntegrationTest (#24046) by Jyun-An Chen · 5 days ago
  40. 8c8818a MINOR: Let ConsumerPerformance#consume return a record instead of mutating AtomicLong argument (#24118) by Lucy Liu · 5 days ago
  41. 85bcc77 MINOR: Log a warning when a listener uses the unsecured OAUTHBEARER validator (#24120) by Aashish Kumar · 5 days ago
  42. 98e0beb MINOR: Assert expected exceptions are thrown (#24107) by Sharang Gupta · 5 days ago
  43. 20fff03 MINOR: Retry share DLQ config setup in the share consume bench worker. (#24110) by Sushant Mahajan · 5 days ago
  44. 11e9247 MINOR: Offset expiration metric counts records of other groups (#24067) by David Jacot · 6 days ago
  45. 4ee4df5 MINOR: Remove unused brokerEpoch from ProducerIdControlManager (#24105) by Russole Chen · 6 days ago
  46. 39ec1e8 KAFKA-21404: Add MirrorStateMessageFormatter (#24077) by Jason Taylor · 6 days ago
  47. c6cca86 MINOR: Make message.max.array.length an internal config by Manikumar Reddy · 6 days ago
  48. d09bd96 MINOR: Reject partitions whose log directory name is too long (#24104) by Aashish Kumar · 6 days ago
  49. a303c93 MINOR: Check topic dictionary index in AssignmentInfo (#24080) by Aashish Kumar · 6 days ago
  50. 2facb62 KAFKA-21410: Do not seed aborted transactions that ended before the cleaning start (#24072) by Mykyta Bozhenko · 7 days ago
  51. f1e6a31 KAFKA-21403: Add mirror state decoder to kafka-dump-log.sh (#24078) by Jason Taylor · 7 days ago
  52. d2e62a6 KAFKA-21224: Add mirror-level configs (#23843) by Federico Valeri · 7 days ago
  53. c13c30d KAFKA-21317: Continue timestamp search across local and remote log segments (#24028) by shantanukawale-stripe · 7 days ago
  54. cbb916e MINOR: Add PartitionsWithLateTransactionsCount description to monitoring.md (#23625) by Kouki · 7 days ago
  55. 08ed8d9 MINOR: Move ConsumerPerformance local state into consume (#23353) by YANG-SYUAN CHOU · 8 days ago
  56. c40d0c9 MINOR: Remove redundant `@Timeout` from ClusterTest classes (#24048) by Parker Chang · 8 days ago
  57. ccf5ec3 KAFKA-21376 Replace AdminUtils leader lookups with AdminClientTestUtils#currentLeader (#23990) by Murali Basani · 8 days ago
  58. 3318552 MINOR: Use diamond operator in StagedMergeIterator tests (#24074) by Kouki · 8 days ago
  59. b1b3c5c MINOR: Fix consumer close timeout version check (#24096) by Russole Chen · 8 days ago
  60. 7699879 KAFKA-21037 Migrate AllocateProducerIdsRequestTest to server module (#23375) by YANG-SYUAN CHOU · 8 days ago
  61. 02b6fa6 MINOR: Reject negative sizes in ByteBufferAccessor (#24069) by Aaron Thomas · 8 days ago
  62. 6c3a595 MINOR: Avoid quadratic null index lookup in ListDeserializer (#24079) by Aashish Kumar · 8 days ago
  63. 1fde64a MINOR: Always compare the password in PlainServerCallbackHandler (#24094) by Aashish Kumar · 8 days ago
  64. 1ae8d6a MINOR: Use a constant-time comparison in PropertyFileLoginModule (#24095) by Aashish Kumar · 8 days ago
  65. bb722b7 KAFKA-20872 Integrate api-checker checks into CI (#23012) by YANG-SYUAN CHOU · 8 days ago
  66. 5de16ed MINOR: Bump snappy-java to 1.1.10.12 (#24084) by winfriedgerlach · 8 days ago
  67. a486c38 KAFKA-21259 Document the case of OffsetOutOfRangeException for Admin#deleteRecords (#24065) by Lucy Liu · 8 days ago
  68. 72955ba MINOR: Fix Javadoc and typos in group-coordinator (#24083) by David Jacot · 8 days ago
  69. 1fdea4a MINOR: Remove unused ProcessState.compareTo and its test (#24087) by Russole Chen · 8 days ago
  70. 487067d KAFKA-21413 Remove onCompleteCallback from PersisterStateManager (#24086) by Yen-Ting Li · 8 days ago
  71. 598caf0 MINOR: Make the message array length limit configurable by Aashish Kumar · 2 weeks ago
  72. 13d7638 MINOR: validate partition in DefaultForeignResponseSinkPartitioner (#24015) by Aashish Kumar · 8 days ago
  73. 2b57423 MINOR: Add 4.4.0 to system tests (#23981) by Omnia Ibrahim · 9 days ago
  74. da53162 MINOR: improve PositionSerde (#23961) by Aashish Kumar · 9 days ago
  75. 9f5cff5 MINOR: improve ChangelogRecordDeserializationHelper (#23960) by Aashish Kumar · 9 days ago
  76. 3bbd45d MINOR: Size PositionSerde buffer in bytes instead of bits (#24039) by Aashish Kumar · 9 days ago
  77. 8aa5700 MINOR: Add missing @Override annotations in group-coordinator (#24066) by David Jacot · 10 days ago
  78. 68986c8 KAFKA-19818 Move ClientQuotaMetadataManager logic to the metadata module (#23555) by majialong · 10 days ago
  79. ab3e73c MINOR: Remove dead code in GroupCoordinatorService (#24051) by David Jacot · 10 days ago
  80. 2bcbbb6 MINOR: Prefix group coordinator logs with [GroupId {}] (#24056) by David Jacot · 10 days ago
  81. bef55c2 MINOR: Log assignor names in share and streams target assignment logs (#24057) by David Jacot · 10 days ago
  82. e1a7df9 MINOR: Use thenApply for synchronous continuations in GroupCoordinatorService (#24059) by David Jacot · 10 days ago
  83. ad8c9c8 MINOR: Remove metadataImage parameter from maybeUpdateStreamsTargetAssignment (#24060) by David Jacot · 10 days ago
  84. 94b8481 KAFKA-18039 Test all versions of quorum responses in RequestResponseTest (#23949) by Russole Chen · 11 days ago
  85. eab1994 KAFKA-20925: Derive the share group state request versions from the request header version (#24000) by Alan Lau · 11 days ago
  86. bb6c417 MINOR: Make ModernGroupMember fields final (#24049) by David Jacot · 11 days ago
  87. 0e5f70c MINOR: Fix Javadoc of Group (#24050) by David Jacot · 11 days ago
  88. 88f297e MINOR: Print class names in group coordinator toString methods (#24041) by David Jacot · 11 days ago
  89. 18fce5c MINOR: Remove unused ShareGroupAutoOffsetResetStrategy factories (#24043) by David Jacot · 11 days ago
  90. 0b021e8 MINOR: Avoid double map lookups in OverlayMap (#24040) by David Jacot · 11 days ago
  91. 98fa512 MINOR: Fix Javadoc of GroupCoordinator (#24044) by David Jacot · 12 days ago
  92. 40a4de9 KAFKA-21398 Fix the docs of UUIDSerializer (#24031) by Russole Chen · 12 days ago
  93. 3e347f1 MINOR: Fix log and exception messages in GroupMetadataManager (#24030) by David Jacot · 12 days ago
  94. bd83759 MINOR: Remove unused streams TopicMetadata (#24035) by David Jacot · 12 days ago
  95. 524279e0 MINOR: Remove stray quotes from ShareGroupMember toString (#24036) by David Jacot · 12 days ago
  96. 74d6179 MINOR: Fix typos in group coordinator config docs (#24037) by David Jacot · 12 days ago
  97. 6eb805e MINOR: Remove always-true topology null check in GroupCoordinatorService (#24038) by David Jacot · 12 days ago
  98. c6ed45d MINOR: Fix pending sync member errors in ClassicGroup (#24032) by David Jacot · 12 days ago
  99. 4e201d7 MINOR: Remove unused Utils.throwIfNotNullOrEmpty (#24029) by David Jacot · 12 days ago
  100. 1393061 KAFKA-20981: fail on an unknown status code in the Streams heartbeat response (#23262) by Matthias J. Sax · 12 days ago