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