How to use Flink Kafka datasource as InputStream I need to run something on Flink that does the following:
