You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ju...@apache.org on 2021/09/16 16:20:19 UTC

[kafka] branch trunk updated (7de8a93 -> 6c80643)

This is an automated email from the ASF dual-hosted git repository.

junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 7de8a93  KAFKA-13162: Ensure ElectLeaders is properly handled in KRaft (#11186)
     add 6c80643  [KAFKA-8522] Streamline tombstone and transaction marker removal (#10914)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   4 +-
 .../common/record/AbstractLegacyRecordBatch.java   |  16 +++
 .../kafka/common/record/DefaultRecordBatch.java    |  77 +++++++-----
 .../apache/kafka/common/record/MemoryRecords.java  | 129 ++++++++++++++++-----
 .../kafka/common/record/MemoryRecordsBuilder.java  |  53 +++++++--
 .../apache/kafka/common/record/RecordBatch.java    |   7 ++
 .../clients/consumer/internals/FetcherTest.java    |   6 +-
 .../common/record/DefaultRecordBatchTest.java      |   2 +-
 .../common/record/MemoryRecordsBuilderTest.java    |  46 ++++++++
 .../kafka/common/record/MemoryRecordsTest.java     |  96 ++++++++++++---
 core/src/main/scala/kafka/log/LogCleaner.scala     | 113 ++++++++++--------
 .../main/scala/kafka/log/LogCleanerManager.scala   |   9 +-
 .../unit/kafka/log/LogCleanerIntegrationTest.scala |   4 +-
 .../unit/kafka/log/LogCleanerManagerTest.scala     |   1 -
 .../test/scala/unit/kafka/log/LogCleanerTest.scala | 108 ++++++++++-------
 .../scala/unit/kafka/log/LogValidatorTest.scala    |   2 +-
 .../test/scala/unit/kafka/log/UnifiedLogTest.scala |  16 +--
 .../apache/kafka/raft/internals/BatchBuilder.java  |   1 +
 18 files changed, 499 insertions(+), 191 deletions(-)