I am trying to implement a gRPC client as a source for my Apache Flink application. The goal is to read streaming data from a gRPC event listener (the gRPC client is salesforce PubSub Api for Change data capture) and process it in Flink. The idea is to schedule multiple grpc client to flink as a source and want to manage this dynamically like remove or adding a new client when required

I am trying to implement a gRPC client as a source for my Apache Flink application. The goal is to read streaming data from a gRPC event listener (the gRPC client is salesforce PubSub Api for Change data capture) and process it in Flink. The idea is to schedule multiple grpc client to flink as a source and want to manage this dynamically like remove or adding a new client when required