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 82c9216c775 KAFKA-14474: Move OffsetIndex to storage module (#13009)
add 7b634c7034c KAFKA-14521: Replace BrokerCompressionCodec with
BrokerCompressionType (#13011)
No new revisions were added by this update.
Summary of changes:
.../kafka/coordinator/group/GroupCoordinator.scala | 6 +-
.../coordinator/group/GroupMetadataManager.scala | 2 +-
.../kafka/coordinator/group/OffsetConfig.scala | 8 +-
.../transaction/TransactionStateManager.scala | 5 +-
core/src/main/scala/kafka/log/LogConfig.scala | 6 +-
core/src/main/scala/kafka/log/LogValidator.scala | 40 +++--
core/src/main/scala/kafka/log/UnifiedLog.scala | 32 ++--
.../scala/kafka/message/CompressionCodec.scala | 108 -------------
core/src/main/scala/kafka/server/KafkaApis.scala | 4 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 16 +-
.../main/scala/kafka/tools/ConsoleProducer.scala | 9 +-
.../scala/kafka/utils/VerifiableProperties.scala | 19 ---
.../server/DynamicBrokerReconfigurationTest.scala | 4 +-
.../scala/other/kafka/TestLinearWriteSpeed.scala | 6 +-
.../group/GroupMetadataManagerTest.scala | 2 +-
.../unit/kafka/log/BrokerCompressionTest.scala | 21 +--
.../scala/unit/kafka/log/LogValidatorTest.scala | 173 ++++++++++-----------
.../kafka/server/AbstractFetcherThreadTest.scala | 5 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 12 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 9 +-
.../unit/kafka/server/ProduceRequestTest.scala | 5 +-
.../CompressedRecordBatchValidationBenchmark.java | 5 +-
.../kafka/server/record/BrokerCompressionType.java | 85 ++++++++++
.../server/record/BrokerCompressionTypeTest.java | 31 ++--
24 files changed, 277 insertions(+), 336 deletions(-)
delete mode 100644 core/src/main/scala/kafka/message/CompressionCodec.scala
create mode 100644
server-common/src/main/java/org/apache/kafka/server/record/BrokerCompressionType.java
copy
clients/src/test/java/org/apache/kafka/common/config/ConfigResourceTest.java =>
server-common/src/test/java/org/apache/kafka/server/record/BrokerCompressionTypeTest.java
(50%)
