[ https://issues.apache.org/jira/browse/FLINK-26645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534296#comment-17534296 ]
Martijn Visser commented on FLINK-26645: ---------------------------------------- Merged into 1.14 as 10e6b3ef591a0c42155f9fd799bf5d53a5f7df4d > Pulsar Source subscribe to a single topic partition will consume all > partitions from that topic > ------------------------------------------------------------------------------------------------ > > Key: FLINK-26645 > URL: https://issues.apache.org/jira/browse/FLINK-26645 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar > Affects Versions: 1.15.0, 1.14.4 > Reporter: Yufei Zhang > Priority: Major > Labels: pull-request-available > Fix For: 1.16.0, 1.14.5 > > > Say users subscribe to 4 partitions of a topic with 16 partitions, current > Pulsar source > will actually consume from all 16 partitions. Expect to consume from 4 > partitions only. -- This message was sent by Atlassian Jira (v8.20.7#820007)