hei, I am interested in running component test with flink. my approach is to use testcontainer to spin a kafka instance and then execute the job that connects to this kafka instance. the problem is that given that is an unbounded stream, the job running in the minicluster keeps executing and I cannot assert anything. One possibility would be to start the job in a different thread but I wonder if there is a better way to do component tests with flink. Thanks in advance!