Hi, In addition to having unit tests for the individual components (map, flatmap, reduce, etc) of my application I would like to write unit tests for the entire flow of my Flink application.
My application reads from Kafka, does various processing and writes out put to both kafka and files. This means I need a controlled (mock) Kafka broker where I can insert a specific sequence of messages, my application that reads from that and then writes the output somewhere else. What is the recommended way of doing this? What tools/example projects are available for building such tests? Thanks. -- Best regards / Met vriendelijke groeten, Niels Basjes
