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 ca15735fa7b MINOR: remove onChange call in stream assignor assign
method (#13034)
add e8232edd24c KAFKA-14477: Move LogValidator and related to storage
module (#13012)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
checkstyle/suppressions.xml | 10 +-
.../apache/kafka/common/utils/PrimitiveRef.java | 23 +
.../kafka/common/utils/PrimitiveRefTest.java | 24 +-
core/src/main/scala/kafka/cluster/Partition.scala | 1 +
.../kafka/common/RecordValidationException.scala | 28 -
.../coordinator/group/GroupMetadataManager.scala | 7 +-
.../transaction/TransactionStateManager.scala | 8 +-
core/src/main/scala/kafka/log/LogSegment.scala | 4 +-
core/src/main/scala/kafka/log/LogValidator.scala | 592 ----------
.../scala/kafka/log/ProducerStateManager.scala | 8 +-
core/src/main/scala/kafka/log/UnifiedLog.scala | 79 +-
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 5 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 6 +-
.../main/scala/kafka/server/ReplicaManager.scala | 4 +-
.../kafka/server/LocalLeaderEndPointTest.scala | 6 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 3 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 13 +-
.../AbstractCoordinatorConcurrencyTest.scala | 4 +-
.../coordinator/group/GroupCoordinatorTest.scala | 10 +-
.../group/GroupMetadataManagerTest.scala | 45 +-
.../transaction/TransactionStateManagerTest.scala | 14 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 4 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 66 +-
.../test/scala/unit/kafka/log/LogTestUtils.scala | 4 +-
.../scala/unit/kafka/log/LogValidatorTest.scala | 1246 ++++++++++----------
.../unit/kafka/log/ProducerStateManagerTest.scala | 40 +-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 22 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 10 +-
.../server/ReplicaManagerConcurrencyTest.scala | 5 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 17 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 6 +-
gradle/spotbugs-exclude.xml | 7 +
.../kafka/jmh/record/BaseRecordBatchBenchmark.java | 5 +-
.../CompressedRecordBatchValidationBenchmark.java | 21 +-
...UncompressedRecordBatchValidationBenchmark.java | 17 +-
.../kafka/server/log/internals/AppendOrigin.java | 45 +
.../kafka/server/log/internals/LogValidator.java | 631 ++++++++++
...hResult.java => RecordValidationException.java} | 23 +-
39 files changed, 1603 insertions(+), 1461 deletions(-)
copy
server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionValidatorTest.java
=> clients/src/test/java/org/apache/kafka/common/utils/PrimitiveRefTest.java
(61%)
delete mode 100644
core/src/main/scala/kafka/common/RecordValidationException.scala
delete mode 100644 core/src/main/scala/kafka/log/LogValidator.scala
create mode 100644
storage/src/main/java/org/apache/kafka/server/log/internals/AppendOrigin.java
create mode 100644
storage/src/main/java/org/apache/kafka/server/log/internals/LogValidator.java
copy
storage/src/main/java/org/apache/kafka/server/log/internals/{TxnIndexSearchResult.java
=> RecordValidationException.java} (56%)
