Flink job testing with

Posted by Chauvet, Thomas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-job-testing-with-tp19573.html

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