satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r711989139
##########
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##########
@@ -81,12 +83,21 @@
// requests calling different methods which use the resources like
producer/consumer managers.
private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
- private final RemotePartitionMetadataStore remotePartitionMetadataStore =
new RemotePartitionMetadataStore();
+ private RemotePartitionMetadataStore remotePartitionMetadataStore;
private volatile TopicBasedRemoteLogMetadataManagerConfig rlmmConfig;
private volatile RemoteLogMetadataTopicPartitioner rlmmTopicPartitioner;
private final Set<TopicIdPartition> pendingAssignPartitions =
Collections.synchronizedSet(new HashSet<>());
private volatile boolean initializationFailed;
+ public TopicBasedRemoteLogMetadataManager() {
Review comment:
This will be used when the remote log subsystem is added and it will be
used as the default RLMM if it is not configured by a user.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
