This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 03b52db MINOR: Improve reproducability of raft simulation tests
(#10422)
add 40f001c KAFKA-12426: Missing logic to create partition.metadata files
in RaftReplicaManager (#10282)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/cluster/Partition.scala | 60 ++----
core/src/main/scala/kafka/log/Log.scala | 44 ++--
core/src/main/scala/kafka/log/LogManager.scala | 26 ++-
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 1 +
core/src/main/scala/kafka/server/KafkaConfig.scala | 3 +-
.../kafka/server/RaftReplicaChangeDelegate.scala | 14 +-
.../scala/kafka/server/RaftReplicaManager.scala | 45 +++-
.../main/scala/kafka/server/ReplicaManager.scala | 60 ++++--
.../kafka/server/metadata/MetadataImage.scala | 8 +
.../src/test/scala/other/kafka/StressTestLog.scala | 4 +-
.../scala/other/kafka/TestLinearWriteSpeed.scala | 2 +-
.../unit/kafka/cluster/AssignmentStateTest.scala | 2 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 18 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 232 +++++++++++++++------
.../scala/unit/kafka/cluster/ReplicaTest.scala | 4 +-
.../log/AbstractLogCleanerIntegrationTest.scala | 4 +-
.../unit/kafka/log/BrokerCompressionTest.scala | 2 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 9 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 6 +-
.../scala/unit/kafka/log/LogConcurrencyTest.scala | 4 +-
.../test/scala/unit/kafka/log/LogManagerTest.scala | 36 ++--
core/src/test/scala/unit/kafka/log/LogTest.scala | 60 ++++--
.../kafka/server/BrokerEpochIntegrationTest.scala | 4 +-
.../server/HighwatermarkPersistenceTest.scala | 6 +-
.../scala/unit/kafka/server/LogOffsetTest.scala | 4 +-
.../server/RaftReplicaChangeDelegateTest.scala | 15 +-
.../unit/kafka/server/RaftReplicaManagerTest.scala | 93 ++++++++-
.../unit/kafka/server/ReplicaManagerTest.scala | 174 ++++++++++------
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 2 +-
.../scala/unit/kafka/utils/SchedulerTest.scala | 2 +-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 4 +-
.../partition/PartitionMakeFollowerBenchmark.java | 9 +-
.../UpdateFollowerFetchStateBenchmark.java | 6 +-
.../apache/kafka/jmh/server/CheckpointBench.java | 3 +-
34 files changed, 674 insertions(+), 292 deletions(-)
