[FLINK-29381] Key_Shared subscription isn't works in the latest Pulsar connector

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.16.0, 1.15.2, 1.14.6
• Fix Version/s: 1.16.0, 1.15.3
• Component/s: Connectors / Pulsar
• Assignee: Yufan Sheng
• Reporter: Yufan Sheng
• Created: 21/Sep/22 12:42
• Updated: 30/Sep/22 04:31
• Resolved: 30/Sep/22 04:31

Description

Pulsar add message retry policy for Key_Shared subscription which makes the flink messages consuming not works now in Key_Shared subscription. We can't consume messages by using a subset of sticky key hash range https://github.com/apache/pulsar/issues/17679. So we have to change the Key_Shared subscription to Exclusive subscription which supports consuming messages with partial key hash ranges.