Hi everybody, I would like to test a kafka / flink process in scala. I would like to proceed as in the integration testing documentation : https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/testing.html#integration-testing with Kafka as source and sink.
For example, I have a topic kafka as source for flink (I use FlinkKafkaConsumer011), then I do some process with Flink, then I send the stream to Kafka (FlinkKafkaProducer011). Any idea on how to do that ? Or better, any example ? Thanks
