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

Reply via email to