[FLINK-3658] Allow the FlinkKafkaProducer to send data to multiple topics

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: Connectors / Kafka
• Assignee: Robert Metzger
• Reporter: Robert Metzger
• Created: 23/Mar/16 09:19
• Updated: 24/Mar/16 11:16
• Resolved: 24/Mar/16 11:16

Description

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.