This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from bd0c628cfc7 KAFKA-19994: TaskManager may not close all tasks on task
timeouts (#21155)
add bf91c079936 KAFKA-15599: Move KafkaMetadataLog to the raft module
(#19762)
No new revisions were added by this update.
Summary of changes:
build.gradle | 5 +-
checkstyle/import-control-jmh-benchmarks.xml | 5 +
checkstyle/import-control-storage.xml | 2 -
checkstyle/import-control.xml | 8 +
.../clients/admin/StaticBrokerConfigTest.java | 2 +-
.../kafka/clients/consumer/ConsumerBounceTest.java | 2 +-
...rsWithCustomForwardingAdminIntegrationTest.java | 2 +-
.../ExactlyOnceSourceIntegrationTest.java | 2 +-
.../main/scala/kafka/raft/KafkaMetadataLog.scala | 746 ------------
.../main/scala/kafka/raft/KafkaRaftManager.scala | 15 +-
.../scala/kafka/server/DynamicBrokerConfig.scala | 4 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 4 +-
.../server/metadata/BrokerMetadataPublisher.scala | 14 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 3 +-
.../DescribeTopicPartitionsRequestHandlerTest.java | 2 +-
.../integration/kafka/api/ConsumerBounceTest.scala | 3 +-
.../kafka/api/IntegrationTestHarness.scala | 4 +-
.../server/DynamicBrokerReconfigurationTest.scala | 2 +-
.../kafka/server/KRaftClusterTest.scala | 3 +-
...ListenersWithSameSecurityProtocolBaseTest.scala | 3 +-
.../kafka/server/QuorumTestHarness.scala | 4 +-
.../kafka/server/RaftClusterSnapshotTest.scala | 6 +-
.../scala/kafka/raft/KafkaMetadataLogTest.scala | 1180 -------------------
.../test/scala/unit/kafka/KafkaConfigTest.scala | 4 +-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 2 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 4 +-
.../kafka/server/BrokerLifecycleManagerTest.scala | 4 +-
.../unit/kafka/server/ControllerApisTest.scala | 4 +-
.../server/ControllerRegistrationManagerTest.scala | 4 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 4 +-
.../unit/kafka/server/KafkaRaftServerTest.scala | 4 +-
.../server/ReplicaManagerConcurrencyTest.scala | 4 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 3 +-
.../unit/kafka/server/ServerShutdownTest.scala | 3 +-
.../test/scala/unit/kafka/server/ServerTest.scala | 3 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 4 +-
.../scala/unit/kafka/tools/StorageToolTest.scala | 4 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 6 +-
.../metadata/KRaftMetadataRequestBenchmark.java | 2 +-
.../java/org/apache/kafka/image/TopicsImage.java | 17 +
.../org/apache/kafka/image/TopicsImageTest.java | 63 +-
.../java/org/apache/kafka/raft}/KRaftConfigs.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 6 +-
.../raft/{ReplicatedLog.java => RaftLog.java} | 2 +-
.../java/org/apache/kafka/raft/RaftManager.java | 4 +-
.../internals/KRaftControlRecordStateMachine.java | 6 +-
.../apache/kafka/raft/internals/KafkaRaftLog.java | 829 ++++++++++++++
.../test/java/org/apache/kafka/raft/MockLog.java | 2 +-
.../apache/kafka/raft/RaftEventSimulationTest.java | 2 +-
.../kafka/raft/internals/KafkaRaftLogTest.java | 1206 ++++++++++++++++++++
.../kafka/server/config/AbstractKafkaConfig.java | 1 +
.../transaction/AddPartitionsToTxnManagerTest.java | 2 +-
.../kafka/storage/internals/log/LogManager.java | 40 +-
.../storage/internals/log/LogManagerTest.java | 109 +-
.../apache/kafka/common/test/ClusterInstance.java | 2 +-
.../kafka/common/test/KafkaClusterTestKit.java | 2 +-
.../apache/kafka/tools/MetadataQuorumCommand.java | 2 +-
59 files changed, 2219 insertions(+), 2166 deletions(-)
delete mode 100644 core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
delete mode 100644 core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala
rename {server/src/main/java/org/apache/kafka/server/config =>
raft/src/main/java/org/apache/kafka/raft}/KRaftConfigs.java (99%)
rename raft/src/main/java/org/apache/kafka/raft/{ReplicatedLog.java =>
RaftLog.java} (99%)
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftLog.java
create mode 100644
raft/src/test/java/org/apache/kafka/raft/internals/KafkaRaftLogTest.java
