Dear flink community, I'm trying to migrate to flink 1.14 from 1.10, I replaced FlinkKafkaConsumer011->KafkaSource and BucketingSink->FileSink without problems. I want to test whole application pipeline but can't find any Source/Sink classes suitable to substitute KafkaSource/FileSink. Previously I used InputFormatSourceFunction/CollectSink for this. Does analogue InputFormatSourceFunction/CollectSink classes exist for Source/Sink? If the aren't can you please advice how can I test whole app pipeline?
