[
https://issues.apache.org/jira/browse/KAFKA-15181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijeet Kumar resolved KAFKA-15181.
------------------------------------
Resolution: Fixed
> Race condition on partition assigned to TopicBasedRemoteLogMetadataManager
> ---------------------------------------------------------------------------
>
> Key: KAFKA-15181
> URL: https://issues.apache.org/jira/browse/KAFKA-15181
> Project: Kafka
> Issue Type: Sub-task
> Components: core
> Reporter: Jorge Esteban Quilcate Otoya
> Assignee: Abhijeet Kumar
> Priority: Major
> Labels: tiered-storage
>
> TopicBasedRemoteLogMetadataManager (TBRLMM) uses a cache to be prepared
> whever partitions are assigned.
> When partitions are assigned to the TBRLMM instance, a consumer is started to
> keep the cache up to date.
> If the cache hasn't finalized to build, TBRLMM fails to return remote
> metadata about partitions that are store on the backing topic. TBRLMM may not
> recover from this failing state.
> A proposal to fix this issue would be wait after a partition is assigned for
> the consumer to catch up. A similar logic is used at the moment when TBRLMM
> writes to the topic, and uses send callback to wait for consumer to catch up.
> This logic can be reused whever a partition is assigned, so when TBRLMM is
> marked as initialized, cache is ready to serve requests.
> Reference: https://github.com/aiven/kafka/issues/33
--
This message was sent by Atlassian Jira
(v8.20.10#820010)