Hi Gordon, Yes, this has been addressed in 1.0.0; and in a very nice way. Thank you.
</CloseThread> Cheers, Sanne On Wed, Dec 7, 2016 at 11:11 AM, Sanne de Roever <sanne.de.roe...@gmail.com> wrote: > Hi Gordon, > > Sounds very close, I will have look; thx. > > Cheers, > > Sanne > > On Wed, Dec 7, 2016 at 11:09 AM, Tzu-Li (Gordon) Tai <tzuli...@apache.org> > wrote: > >> Hi, >> >> The FlinkKafkaProducers currently support per record topic through the >> user-provided serialization schema which has a "getTargetTopic(T >> element)" method called for per record, >> and also decides the partition the record will be sent to through >> a custom KafkaPartitioner, which is also provided >> by the user when creating a FlinkKafkaProducer. >> >> Does this already provide the functionality you’ve mentioned? Or have I >> misunderstood what you have in mind? >> >> Cheers, >> Gordon >> >> >> On December 7, 2016 at 5:55:24 PM, Sanne de Roever ( >> sanne.de.roe...@gmail.com) wrote: >> >> The next step would be to determine the impact on the interface of a >> Sink. Currently a Kafka sink has one topic, for example: >> >> >
