Hello,
We have Flink job that read data from multiple Kafka topics, transforms data
and write in output Kafka topics. We want write integration test for it. I've
looked at KafkaTableITCase, we can do similar setup of Kafka topics,
prepopulate data but since in our case it is endless stream, we need after some
timeout (or condition on output topics) stop the job. Should we run
'env.execute("Job");` on background thread and then in main thread wait and
then interrupt background thread? Or maybe there is dedicated method to
stop/cancel job when needed. Are there better examples of Integration Tests for
jobs with endless stream?
Thanks,
Alexey
