[FLINK-25013] flink pulsar connector cannot consume deferred messages

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.14.0
• Component/s: Connectors / Pulsar
• Assignee: Unassigned
• Reporter: zhangjg
• Created: 23/Nov/21 10:49
• Updated: 24/Nov/21 08:31
• Resolved: 24/Nov/21 08:31

Description

 

at flink 1.14.0 version ,  pulsar connector ( PulsarSource) cannot consume deferred messages . 

For the message sent by the producer, the flink pulsar source will be consumed immediately