[FLINK-9641] Pulsar Source Connector

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Abandoned
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Chris Kellogg
• Created: 21/Jun/18 22:22
• Updated: 08/Jan/20 10:55
• Resolved: 08/Jan/20 10:55

Description

Pulsar (https://github.com/apache/incubator-pulsar) is a distributed pub-sub messaging system currently in apache incubation. It is a very active project and there are committers from various companies and good adoption. This pr will add a source function to allow Flink jobs to process messages from Pulsar topics.

 

Issue Links

• supercedes: FLINK-9032 Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE
• links to: GitHub Pull Request #6200
• links to: GitHub Pull Request #6200