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