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%)
