Hello everyone, 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 production. 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! Best, Richard Deurwaarder
