[
https://issues.apache.org/jira/browse/FLINK-3658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208160#comment-15208160
]
ASF GitHub Bot commented on FLINK-3658:
---------------------------------------
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1832
[FLINK-3658][Kafka] Allow producing into multiple topics
Kafka's Producer API allows to send messages to any available topic. This
was not exposed in the Flink APIs.
With this change, the topic specified when creating the producer is the
default target topic.
With the `KeyedSerializationSchema`, users can now, based on each record's
data, also override the target topic.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3658
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1832.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1832
----
----
> Allow the FlinkKafkaProducer to send data to multiple topics
> ------------------------------------------------------------
>
> Key: FLINK-3658
> URL: https://issues.apache.org/jira/browse/FLINK-3658
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Affects Versions: 1.0.0
> Reporter: Robert Metzger
> Assignee: Robert Metzger
>
> Currently, the FlinkKafkaProducer is sending all events to one topic defined
> when creating the producer.
> We could allow users to send messages to multiple topics by extending the
> {{KeyedSerializationSchema}} by a method {{public String getTargetTopic(T
> element)}} which overrides the default topic if the return value is not null.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
