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 yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199548194
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java
---
@@ -0,0 +1,203
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199546643
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/Defaults.java
---
@@ -0,0 +1,30 @@
+/*
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199549195
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarSourceBase.java
---
@@ -0,0 +1,30 @@
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6200#discussion_r199551693
--- Diff:
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
---
@@ -0,0
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)
10 matches
Mail list logo