[
https://issues.apache.org/jira/browse/FLINK-36210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaochen.zhou updated FLINK-36210:
----------------------------------
Description: In {{TopicPatternSubscriber}} mode, our current logic for
fetch topic metadata for all topics and then filtering it. We can optimize this
by first filtering the topic names and then fetch metadata only for the
filtered topics to speed up task recovery. (was: In {{TopicPatternSubscriber}}
mode, our current logic for fetch topic metadata for all topics and then
filtering it. We can optimize this by first filtering the topic names and then
fetch metadata only for the filtered topics.)
> Optimize the logic for fetching topic metadata in the TopicPatternSubscriber
> mode
> ---------------------------------------------------------------------------------
>
> Key: FLINK-36210
> URL: https://issues.apache.org/jira/browse/FLINK-36210
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: xiaochen.zhou
> Priority: Major
> Labels: pull-request-available
>
> In {{TopicPatternSubscriber}} mode, our current logic for fetch topic
> metadata for all topics and then filtering it. We can optimize this by first
> filtering the topic names and then fetch metadata only for the filtered
> topics to speed up task recovery.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)