GitHub user XiaoZYang reopened a pull request:
https://github.com/apache/flink/pull/5845
[FLINK-9168][flink-connectors]Pulsar Sink connector
## What is the purpose of the change
Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink
connector for flink.
##
Github user XiaoZYang closed the pull request at:
https://github.com/apache/flink/pull/5845
---
Github user XiaoZYang commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r194076473
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java
---
@@ -0,0 +1,304
Github user surryr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r193793061
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java
---
@@ -0,0 +1,304 @@
GitHub user XiaoZYang reopened a pull request:
https://github.com/apache/flink/pull/5845
[FLINK-9168][flink-connectors]Pulsar Sink connector
## What is the purpose of the change
Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink
connector for flink.
##
Github user XiaoZYang closed the pull request at:
https://github.com/apache/flink/pull/5845
---
Github user sijie commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r188867505
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java
---
@@ -0,0 +1,36 @@
Github user sijie commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r188867435
--- Diff:
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducerTest.java
---
@@ -0,0 +1,100
Github user pluppens commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r187085104
--- Diff:
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducerTest.java
---
@@ -0,0
Github user pluppens commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r187084563
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java
---
@@ -0,0 +1,36 @@
GitHub user XiaoZYang opened a pull request:
https://github.com/apache/flink/pull/5845
[FLINK-9168][flink-connectors]Pulsar Sink connector
## What is the purpose of the change
Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink
connector for flink.
##
11 matches
Mail list logo