[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r623253824 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java ## @@ -0,0

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r623251580 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/BytesApiMessageSerde.java ## @@ -0,0 +1,68 @@ +/* +

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r621418419 ## File path: storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSerdeTest.java ## @@ -0,0 +1,111 @@ +/* + *

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r620461362 ## File path: storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadata.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r620455106 ## File path: raft/src/main/java/org/apache/kafka/raft/metadata/AbstractMetadataRecordSerde.java ## @@ -0,0 +1,82 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r620449297 ## File path: raft/src/main/java/org/apache/kafka/raft/metadata/AbstractMetadataRecordSerde.java ## @@ -0,0 +1,82 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r619545527 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataContext.java ## @@ -0,0 +1,74 @@ +/* + *

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r617904827 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/AbstractApiMessageAndVersionSerde.java ## @@ -0,0

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r617765100 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java ## @@ -0,0

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r616879405 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java ## @@ -0,0

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r616081872 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerdes.java ## @@ -0,0 +1,54 @@

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r614993697 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerdes.java ## @@ -0,0 +1,56 @@

[GitHub] [kafka] junrao commented on a change in pull request #10271: KAFKA-12429: Added serdes for the default implementation of RLMM based on an internal topic as storage.

junrao commented on a change in pull request #10271: URL: https://github.com/apache/kafka/pull/10271#discussion_r614448708 ## File path: storage/src/main/resources/message/RemotePartitionDeleteMetadata.json ## @@ -0,0 +1,68 @@ +// Licensed to the Apache Software Foundation