Robert Metzger created FLINK-3658: ------------------------------------- Summary: 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)