Hi, I am able to read from a topic using FlinkKafkaConsumer and return the result, however when I am testing this scenario in Junit the result is getting printed(kafkaStream.print()) but I am not able to exit the Job, env.execute keeps running, I tried to return env.execute from method but that did not work either.
1) Is there any way to end the execution of job forcefully. 2) How do I test if the data has come from topic - One way I think of is to get the output of stream.print() in a PrintStream and check the result.(but not able to test this since job is not getting exited) Please help with these issues Regards, Vinay Patil
