I have a flink job that reads message from a topic and sends it to another topic, very basic in terms o