You are right, it does not exist, and it would be a nice addition.
Can you sketch some details on how to do that?
- Will it be a new type of producer? If yes, can as much as possible of
the code be shared between the current and the new producer?
- Will it only be part of the Flink Kafka 0.10 producer?
Thanks,
Stephan
On Tue, Dec 6, 2016 at 2:23 PM, Sanne de Roever <sanne.de.roe...@gmail.com>
wrote:
> 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
>
