Hi, I'm working on a pyflink datastream connector for Pravega and wish to use a datasource other than Kafka.
Currently the Kafka connector for the python datastream api is implemented using a ` get_gateway` function which creates a binding to java in ` FlinkKafkaConsumer`. So if I want to create a `FlinkPrevegaReader` that consumes other datasource like the Pravega, is it recommended to do in the same way? (we have a java reader/consumer implementation) Or the gateway thing might be changed in the future? PS: In this post(https://stackoverflow.com/questions/65009292/is-there-a-kinesis-connector-for-pyflink) Xingbo suggested that the Kinesis and other connectors will be added soon, but I'm not sure whether it uses the same technique mentioned above. Thanks, Zhongle Wang
