clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1276543815
##
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/NoOpRemoteLogMetadataManager.java:
##
@@ -74,6 +74,11 @@ public void
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1276037068
##
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerTest.java:
##
@@ -168,4 +169,64 @@ private void
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1276036551
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java:
##
@@ -327,6 +327,17 @@ public void
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1275018018
##
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerTest.java:
##
@@ -168,4 +169,64 @@ private void
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1274701153
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java:
##
@@ -327,6 +327,17 @@ public void
clolov commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1273206652
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##
@@ -201,4 +201,13 @@ void onPartitionLeadershipChanges(Set