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

Posted to commits@kafka.apache.org by gu...@apache.org on 2019/06/21 19:44:59 UTC

[kafka] branch trunk updated (11b25a1 -> 3e9d1c1)

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

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


    from 11b25a1  MINOR: Fix DistributedHerderTest after adding reason to maybeLeaveGroup (#6982)
     add 3e9d1c1  KAFKA-8106: Skipping ByteBuffer allocation of key / value / headers in logValidator (#6785)

No new revisions were added by this update.

Summary of changes:
 .../producer/internals/TransactionManager.java     |  12 +-
 .../common/record/AbstractLegacyRecordBatch.java   |  12 +-
 .../kafka/common/record/AbstractRecordBatch.java   |   2 +-
 .../kafka/common/record/AbstractRecords.java       |   6 +-
 .../apache/kafka/common/record/DefaultRecord.java  | 173 ++++++++++++++-
 .../kafka/common/record/DefaultRecordBatch.java    | 113 +++++++---
 .../kafka/common/record/MemoryRecordsBuilder.java  |   4 +-
 .../kafka/common/record/MutableRecordBatch.java    |   9 +
 .../kafka/common/record/PartialDefaultRecord.java  |  99 +++++++++
 .../kafka/common/utils/CloseableIterator.java      |  22 ++
 .../{OperatingSystem.java => PrimitiveRef.java}    |  24 ++-
 .../common/record/DefaultRecordBatchTest.java      |  26 +++
 .../kafka/common/record/DefaultRecordTest.java     | 235 +++++++++++++++++++++
 core/src/main/scala/kafka/log/LogValidator.scala   | 119 ++++++-----
 .../scala/unit/kafka/log/LogValidatorTest.scala    |  57 ++---
 .../jmh/record/RecordBatchIterationBenchmark.java  |  25 ++-
 16 files changed, 794 insertions(+), 144 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java
 copy clients/src/main/java/org/apache/kafka/common/utils/{OperatingSystem.java => PrimitiveRef.java} (69%)