Hi, Kafka producer clients for 0.10 allow the following syntax:
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i))); The gist is that one producer can send messages to different topics; it is useful for event routing ao. It makes the creation generic endpoints easier. If I am right, Flink currently does not support this; would this be a useful addition? Cheers, Sanne