[ https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yufan Sheng updated FLINK-27400: -------------------------------- Description: Pulsar has a lot of internal topics which is used for metadata. It couldn't be consumed directly by the user. We accidentally exposed these topics to end-users when using the regex topics. (was: UnroderdPulsarSourceReader currently calls reconsume, but this feature relys on retry topic. But if retry topic is enabled the initial search will only support earliest and lates (because it will be a multiconsumer impl). We plan to delete the reconsume logic to get rid of dependency on retry topic and should disable retry.) > Pulsar connector subscribed the system topic when using the regex > ----------------------------------------------------------------- > > Key: FLINK-27400 > URL: https://issues.apache.org/jira/browse/FLINK-27400 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar > Affects Versions: 1.15.0, 1.14.4, 1.16.0 > Reporter: Yufan Sheng > Assignee: Yufan Sheng > Priority: Major > Labels: pull-request-available > Fix For: 1.16.0, 1.15.2, 1.14.6 > > > Pulsar has a lot of internal topics which is used for metadata. It couldn't > be consumed directly by the user. We accidentally exposed these topics to > end-users when using the regex topics. -- This message was sent by Atlassian Jira (v8.20.7#820007)