I would like start adding some google cloud connectors starting with a PubSub Source. I have a basic implementation ready but I want it to be able to:
- easily scale up (should I have it extend RichParallelSourceFunction for this?)
- Make it easier to provide the google cloud credentials. This would require being able to send some json string / ServiceAccount to the nodes when starting up this source.
Could this be something that would be useful for others and added to the flink connectors repo?