You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2021/05/11 16:59:51 UTC
[kafka] branch trunk updated (80a468e -> 7ef3879)
This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 80a468e MINOR Removed copying storage libraries specifically as they are already copied. (#10647)
add 7ef3879 KAFKA-12758 Added `server-common` module to have server side common classes. (#10638)
No new revisions were added by this update.
Summary of changes:
build.gradle | 64 +++++++++++++++++++++-
checkstyle/import-control-core.xml | 1 +
checkstyle/import-control.xml | 18 ++++--
core/src/main/scala/kafka/raft/RaftManager.scala | 5 +-
.../main/scala/kafka/server/ControllerApis.scala | 4 +-
.../main/scala/kafka/server/ControllerServer.scala | 4 +-
.../main/scala/kafka/server/KafkaRaftServer.scala | 3 +-
.../main/scala/kafka/tools/TestRaftServer.scala | 3 +-
.../java/kafka/testkit/KafkaClusterTestKit.java | 2 +-
.../scala/kafka/raft/KafkaMetadataLogTest.scala | 4 +-
.../unit/kafka/server/ControllerApisTest.scala | 5 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 3 +-
.../controller/ClientQuotaControlManager.java | 2 +-
.../kafka/controller/ClusterControlManager.java | 2 +-
.../controller/ConfigurationControlManager.java | 2 +-
.../apache/kafka/controller/ControllerResult.java | 2 +-
.../controller/ControllerResultAndOffset.java | 2 +-
.../kafka/controller/FeatureControlManager.java | 2 +-
.../kafka/controller/NoOpSnapshotWriter.java | 2 +-
.../apache/kafka/controller/QuorumController.java | 2 +-
.../controller/ReplicationControlManager.java | 2 +-
.../apache/kafka/controller/SnapshotGenerator.java | 2 +-
.../apache/kafka/controller/SnapshotWriter.java | 2 +-
.../org/apache/kafka/metalog/MetaLogManager.java | 2 +-
.../controller/ClientQuotaControlManagerTest.java | 2 +-
.../controller/ClusterControlManagerTest.java | 2 +-
.../ConfigurationControlManagerTest.java | 2 +-
.../kafka/controller/ControllerTestUtils.java | 2 +-
.../controller/FeatureControlManagerTest.java | 2 +-
.../kafka/controller/MockSnapshotWriter.java | 2 +-
.../kafka/controller/QuorumControllerTest.java | 2 +-
.../controller/ReplicationControlManagerTest.java | 2 +-
.../kafka/controller/SnapshotGeneratorTest.java | 2 +-
.../org/apache/kafka/metalog/LocalLogManager.java | 2 +-
.../apache/kafka/metalog/LocalLogManagerTest.java | 2 +-
.../java/org/apache/kafka/raft/BatchReader.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 1 +
.../kafka/raft/internals/BatchAccumulator.java | 2 +-
.../apache/kafka/raft/internals/BatchBuilder.java | 2 +-
.../kafka/raft/internals/RecordsBatchReader.java | 2 +-
.../kafka/raft/internals/RecordsIterator.java | 2 +-
.../apache/kafka/raft/internals/StringSerde.java | 2 +-
.../kafka/raft/metadata/MetaLogRaftShim.java | 2 +-
.../kafka/raft/metadata/MetadataRecordSerde.java | 1 +
.../org/apache/kafka/snapshot/SnapshotReader.java | 2 +-
.../org/apache/kafka/snapshot/SnapshotWriter.java | 2 +-
.../apache/kafka/raft/RaftClientTestContext.java | 1 +
.../apache/kafka/raft/RaftEventSimulationTest.java | 1 +
.../kafka/raft/internals/RecordsIteratorTest.java | 2 +-
.../raft/metadata/MetadataRecordSerdeTest.java | 2 +-
.../kafka/server/common}/ApiMessageAndVersion.java | 2 +-
.../serialization}/AbstractApiMessageSerde.java | 5 +-
.../serialization/BytesApiMessageSerde.java | 14 ++---
.../server/common/serialization}/RecordSerde.java | 2 +-
settings.gradle | 1 +
.../apache/kafka/shell/MetadataNodeManager.java | 2 +-
.../java/org/apache/kafka/shell/MetadataShell.java | 2 +-
.../org/apache/kafka/shell/SnapshotFileReader.java | 2 +-
.../serialization/RemoteLogMetadataSerde.java | 3 +-
.../serialization/RemoteLogMetadataTransform.java | 2 +-
.../RemoteLogSegmentMetadataTransform.java | 2 +-
.../RemoteLogSegmentMetadataUpdateTransform.java | 2 +-
.../RemotePartitionDeleteMetadataTransform.java | 2 +-
.../storage/RemoteLogMetadataTransformTest.java | 2 +-
64 files changed, 152 insertions(+), 79 deletions(-)
rename {metadata/src/main/java/org/apache/kafka/metadata => server-common/src/main/java/org/apache/kafka/server/common}/ApiMessageAndVersion.java (97%)
rename {raft/src/main/java/org/apache/kafka/raft/metadata => server-common/src/main/java/org/apache/kafka/server/common/serialization}/AbstractApiMessageSerde.java (96%)
rename {storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage => server-common/src/main/java/org/apache/kafka/server/common}/serialization/BytesApiMessageSerde.java (83%)
rename {raft/src/main/java/org/apache/kafka/raft => server-common/src/main/java/org/apache/kafka/server/common/serialization}/RecordSerde.java (97%)