如果我能很好地理解你的问题，我想你可以用一个接收器来解决它，因为你可以根据正在处理的记录来选择Kafka主题。似乎源代码中的一个元素可能被写入多个主题，在这种情况下，您需要一个flatmapfunction将每个源记录复制n次（每个输出主题一个）。我建议将输出作为一对（aka Tuple2 )与（主题，记录）。

DataStream<Tuple2<String, MyValue>> stream = input.flatMap(new FlatMapFunction<>() {
    public void flatMap(MyValue value, Collector<Tupple2<String, MyValue>> out) {
        for (String topic : topics) {
            out.collect(Tuple2.of(topic, value));
        }
    }
});

然后，您可以使用前面通过创建具有keyedserializationschema的flinkkafkaproducer计算的主题，在其中实现 getTargetTopic 返回对的第一个元素。

stream.addSink(new FlinkKafkaProducer10<>(
        "default-topic",
        new KeyedSerializationSchema<>() {
            public String getTargetTopic(Tuple2<String, MyValue> element) {
                return element.f0;
            }
            ...
        },
        kafkaProperties)
);