I've had success using Kafka for Junit,
https://github.com/mguenther/kafka-junit, for these kinds of tests.
On Wed, Apr 20, 2022 at 3:01 PM Alexey Trenikhun <yen...@msn.com> wrote:
>
> 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
--
Cheers,
Aeden
GitHub: https://github.com/aedenj
Linked In: http://www.linkedin.com/in/aedenjameson
