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/05 14:50:23 UTC
[kafka] branch trunk updated (9a71468 -> a1367f5)
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 9a71468 KAFKA-10767: Adding test cases for all, reverseAll and reverseRange for ThreadCache (#9779)
add a1367f5 KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage. (#10271)
No new revisions were added by this update.
Summary of changes:
build.gradle | 20 +++-
checkstyle/import-control.xml | 4 +-
checkstyle/suppressions.xml | 2 +
.../java/org/apache/kafka/raft/RecordSerde.java | 2 +-
...cordSerde.java => AbstractApiMessageSerde.java} | 43 +++++--
.../kafka/raft/metadata/MetadataRecordSerde.java | 44 +------
.../log/remote/storage/RemoteLogMetadata.java | 37 +++---
.../remote/storage/RemoteLogSegmentMetadata.java | 49 +++-----
.../storage/RemoteLogSegmentMetadataUpdate.java | 43 ++-----
.../storage/RemotePartitionDeleteMetadata.java | 50 +++-----
.../serialization/BytesApiMessageSerde.java | 68 +++++++++++
.../serialization/RemoteLogMetadataSerde.java | 104 +++++++++++++++++
.../serialization/RemoteLogMetadataTransform.java | 52 +++++++++
.../RemoteLogSegmentMetadataTransform.java | 98 ++++++++++++++++
.../RemoteLogSegmentMetadataUpdateTransform.java | 59 ++++++++++
.../RemotePartitionDeleteMetadataTransform.java | 54 +++++++++
.../message/RemoteLogSegmentMetadata.json | 126 +++++++++++++++++++++
.../message/RemoteLogSegmentMetadataUpdate.json | 82 ++++++++++++++
.../message/RemotePartitionDeleteMetadata.json | 68 +++++++++++
.../storage/RemoteLogMetadataSerdeTest.java | 111 ++++++++++++++++++
.../storage/RemoteLogMetadataTransformTest.java | 85 ++++++++++++++
21 files changed, 1029 insertions(+), 172 deletions(-)
copy raft/src/main/java/org/apache/kafka/raft/metadata/{MetadataRecordSerde.java => AbstractApiMessageSerde.java} (56%)
copy clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java => storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadata.java (52%)
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/BytesApiMessageSerde.java
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataTransform.java
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataUpdateTransform.java
create mode 100644 storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemotePartitionDeleteMetadataTransform.java
create mode 100644 storage/src/main/resources/message/RemoteLogSegmentMetadata.json
create mode 100644 storage/src/main/resources/message/RemoteLogSegmentMetadataUpdate.json
create mode 100644 storage/src/main/resources/message/RemotePartitionDeleteMetadata.json
create mode 100644 storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSerdeTest.java
create mode 100644 storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataTransformTest.java