[FLINK-20726] Introduce Pulsar connector

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Done
• Affects Version/s: 1.13.0
• Fix Version/s: 1.17.0
• Component/s: Connectors / Common
• Labels: auto-unassigned
• Assignee: Unassigned
• Reporter: Jianyun Zhao
• Created: 22/Dec/20 17:33
• Updated: 27/Sep/22 14:06
• Resolved: 27/Sep/22 14:06

Description

Pulsar is an important player in messaging middleware, and it is essential for Flink to support Pulsar.

Our existing code is maintained at streamnative/pulsar-flink , next we will split it into several pr merges back to the community.

 

Sub-Tasks

• Pulsar SourceFunction: Closed
• Pulsar SinkFunction: Closed
• Pulsar DynamicTable: Closed
• Pulsar Catalog: Closed
• Pulsar Source: Resolved
• Introduce the upsert-pulsar Connector: Resolved
• The document for Pulsar Source: Resolved
• Embedded Pulsar broker backend for testing: Resolved
• Test Pulsar source end 2 end: Closed
• Support Pulsar source connector in Python DataStream API.: Closed