[ https://issues.apache.org/jira/browse/FLINK-26713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser closed FLINK-26713. ---------------------------------- Resolution: Duplicate > Flink Pulsar connector isue > --------------------------- > > Key: FLINK-26713 > URL: https://issues.apache.org/jira/browse/FLINK-26713 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar > Affects Versions: 1.14.3 > Reporter: Vijaya Bhaskar V > Priority: Major > > Flink Pulsar Connector version 1.14.3 when we subscribed to partitioned > topics it is listening to all the partitions instead of specified partitions. > Used the following options: > > Exclusive subscription, 16 partitions, tried to consume from 4 partitions and > it is consuming from all partitions -- This message was sent by Atlassian Jira (v8.20.7#820007)