flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chauvet, Thomas" <Thomas.Chau...@ercom.fr>
Subject Flink job testing with
Date Tue, 17 Apr 2018 14:16:49 GMT
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 ?


View raw message