flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sanne de Roever <sanne.de.roe...@gmail.com>
Subject Re: Flink Kafka producer with a topic per message
Date Wed, 07 Dec 2016 10:11:48 GMT
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 <tzulitai@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.roever@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:
>
>

Mime
View raw message