PubSub connector (FLINK-9311)
A while back I opened this Jira issue:
https://issues.apache.org/jira/browse/FLINK-9311. It is regarding a new
Flink connector for Google PubSub.
At Bol.com, the company I work for, we are going to use this connector to
do our financial processing. My colleague, Niels Basjes, and I have
finished implementing this and we are about ready to start running it in
We would like to donate this code and have opened a pull request (
https://github.com/apache/flink/pull/6594). The pull request contains:
- a SourceFunction (with 2 test versions)
- a SinkFunction
- an example application
- and End-to-End tests using a docker container
Yanghua has taken a glance at the code and already provided us with some
feedback. We would like to invite others to provide additional feedback.
I hope you find this useful and will consider merging the PR!