[ 
https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749058#comment-17749058
 ] 

Owen C.H. Leung commented on KAFKA-15038:
-----------------------------------------

[~divijvaidya] I'd like to pick this up. I've done a bit diving and would like 
to clarify if my understanding is correct : 

So essentially, in this ticket we want to remove the use of 
`ConcurrentMap<TopicPartition, Uuid> topicPartitionIds`, and leverage the cache 
available in `RemoteLogManagerConfig rlmConfig` (to be more specific, use 
metadata manager in the `Map<String, Object> remoteLogMetadataManagerProps()` ) 
to serve as the cache, which will be the single source of authority ? 

Let me know. Thanks

> Use topic id/name mapping from the Metadata cache in the RemoteLogManager
> -------------------------------------------------------------------------
>
>                 Key: KAFKA-15038
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15038
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: core
>            Reporter: Alexandre Dupriez
>            Assignee: Owen C.H. Leung
>            Priority: Minor
>
> Currently, the {{RemoteLogManager}} maintains its own cache of topic name to 
> topic id 
> [[1]|https://github.com/apache/kafka/blob/trunk/core/src/main/java/kafka/log/remote/RemoteLogManager.java#L138]
>  using the information provided during leadership changes, and removing the 
> mapping upon receiving the notification of partition stopped.
> It should be possible to re-use the mapping in a broker's metadata cache, 
> removing the need for the RLM to build and update a local cache thereby 
> duplicating the information in the metadata cache. It also allows to preserve 
> a single source of authority regarding the association between topic names 
> and ids.
> [1] 
> https://github.com/apache/kafka/blob/trunk/core/src/main/java/kafka/log/remote/RemoteLogManager.java#L138



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to