[FLINK-20731] Pulsar Source

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.0
• Fix Version/s: 1.14.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Release Note: Flink now directly provides a way to read data from Pulsar with DataStream API.
• Assignee: Yufan Sheng
• Reporter: Jianyun Zhao
• Created: 22/Dec/20 17:40
• Updated: 21/Nov/22 05:26
• Resolved: 16/Aug/21 21:37

Description

This is our implementation based on FLIP-27.

Issue Links

• causes: FLINK-23848 PulsarSourceITCase is failed on Azure
• causes: FLINK-30109 Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar
• links to: GitHub Pull Request #15304