[GitHub] [kafka] ccding commented on a change in pull request #10579: KAFKA-9555 Added default RLMM implementation based on internal topic storage.

ccding commented on a change in pull request #10579: URL: https://github.com/apache/kafka/pull/10579#discussion_r664632598 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java ## @@ -51,6 +58,7 @@ */

[GitHub] [kafka] ccding commented on a change in pull request #10579: KAFKA-9555 Added default RLMM implementation based on internal topic storage.

ccding commented on a change in pull request #10579: URL: https://github.com/apache/kafka/pull/10579#discussion_r664630725 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java ## @@ -220,16 +227,16 @@ public boolean isPartit

[GitHub] [kafka] ccding commented on a change in pull request #10579: KAFKA-9555 Added default RLMM implementation based on internal topic storage.

ccding commented on a change in pull request #10579: URL: https://github.com/apache/kafka/pull/10579#discussion_r656735781 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java ## @@ -0,0 +1,139 @@ +/* + * Licensed to the