[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

PubSub connector (FLINK-9311)

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

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!


Richard Deurwaarder