This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from b3313b8 KAFKA-12297: Make MockProducer return RecordMetadata with
values as per contract
add 744d05b KAFKA-12327: Remove MethodHandle usage in CompressionType
(#10123)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 12 +++-
.../kafka/clients/consumer/internals/Fetcher.java | 2 +-
.../KafkaLZ4BlockInputStream.java | 11 +--
.../KafkaLZ4BlockOutputStream.java | 2 +-
.../SnappyFactory.java} | 35 +++++----
.../apache/kafka/common/compress/ZstdFactory.java | 58 +++++++++++++++
.../common/record/AbstractLegacyRecordBatch.java | 1 +
.../kafka/common/record/CompressionType.java | 82 +++++-----------------
.../kafka/common/record/DefaultRecordBatch.java | 1 +
.../kafka/common/record/FileLogInputStream.java | 1 +
.../apache/kafka/common/record/MemoryRecords.java | 1 +
.../kafka/common/record/MutableRecordBatch.java | 1 +
.../apache/kafka/common/record/RecordBatch.java | 1 +
.../common/{record => utils}/BufferSupplier.java | 2 +-
.../clients/consumer/internals/FetcherTest.java | 2 +-
.../common/{record => compress}/KafkaLZ4Test.java | 5 +-
.../kafka/common/record/BufferSupplierTest.java | 1 +
.../kafka/common/record/CompressionTypeTest.java | 3 +
.../common/record/DefaultRecordBatchTest.java | 1 +
.../kafka/common/record/MemoryRecordsTest.java | 1 +
core/src/main/scala/kafka/log/LogCleaner.scala | 3 +-
core/src/main/scala/kafka/log/LogSegment.scala | 3 +-
core/src/main/scala/kafka/log/LogValidator.scala | 5 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 3 +-
gradle/spotbugs-exclude.xml | 2 +-
.../kafka/jmh/record/BaseRecordBatchBenchmark.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 2 +-
.../kafka/raft/internals/RecordsBatchReader.java | 2 +-
.../raft/internals/RecordsBatchReaderTest.java | 2 +-
.../apache/kafka/snapshot/FileRawSnapshotTest.java | 2 +-
.../apache/kafka/snapshot/SnapshotWriterTest.java | 2 +-
31 files changed, 142 insertions(+), 109 deletions(-)
rename clients/src/main/java/org/apache/kafka/common/{record =>
compress}/KafkaLZ4BlockInputStream.java (95%)
rename clients/src/main/java/org/apache/kafka/common/{record =>
compress}/KafkaLZ4BlockOutputStream.java (99%)
copy
clients/src/main/java/org/apache/kafka/common/{record/RecordBatchIterator.java
=> compress/SnappyFactory.java} (53%)
create mode 100644
clients/src/main/java/org/apache/kafka/common/compress/ZstdFactory.java
rename clients/src/main/java/org/apache/kafka/common/{record =>
utils}/BufferSupplier.java (99%)
rename clients/src/test/java/org/apache/kafka/common/{record =>
compress}/KafkaLZ4Test.java (98%)
