Skip to content
This repository was archived by the owner on Jan 12, 2026. It is now read-only.

[WIP] to #123, support pulsar connector source#188

Open
qidian99 wants to merge 1 commit intobytedance:masterfrom
qidian99:issue/#123_support_pulsar_source_connector
Open

[WIP] to #123, support pulsar connector source#188
qidian99 wants to merge 1 commit intobytedance:masterfrom
qidian99:issue/#123_support_pulsar_source_connector

Conversation

@qidian99
Copy link

Signed-off-by:

to #123, support pulsar connector source

@qidian99 qidian99 force-pushed the issue/#123_support_pulsar_source_connector branch 4 times, most recently from 72420fc to 1355d76 Compare November 18, 2022 20:36
Added pulsar source v1

Pulsar source connector adapt to bitsail v1 source reader.

Wired up bitsail config for Pulsar connector

Simple implementation of pollNext function in Pulsar connector
@qidian99 qidian99 force-pushed the issue/#123_support_pulsar_source_connector branch from 1355d76 to 51f2429 Compare November 18, 2022 20:37
</dependency>
<dependency>
<groupId>io.streamnative.connectors</groupId>
<artifactId>pulsar-flink-connector_${scala.binary.version}</artifactId>
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we can't dependency flink conector when use v1 version interface..

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants