Github user cckellogg commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r203863637
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java
---
@@ -0,0 +1,203
Github user cckellogg commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199909793
--- Diff:
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
---
@@ -0,0
Github user cckellogg commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199909775
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarSourceBase.java
---
@@ -0,0 +1,30
Github user cckellogg commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199909645
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/Defaults.java
---
@@ -0,0 +1,30
Github user cckellogg commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199909617
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java
---
@@ -0,0 +1,203
GitHub user cckellogg opened a pull request:
https://github.com/apache/flink/pull/6200
[FLINK-9641] [streaming-connectors] Flink pulsar source connector
## What is the purpose of the change
This pull request adds a
[pulsar](https://github.com/apache/incubator-pulsar
Github user cckellogg closed the pull request at:
https://github.com/apache/flink/pull/6190
---
GitHub user cckellogg opened a pull request:
https://github.com/apache/flink/pull/6190
Add a simple pulsar source connector.
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution
