1.15版本的flink往kafka多个topic写消息，是自定义实现KafkaSerializat

是的，在Flink 1.15版本中向多个Kafka topic写入消息需要实现自定义的KafkaSerializationSchema。用于将消息转换为Kafka可以识别的二进制数据，以写入Kafka topic。实现的方法如下： public class MyKafkaSerializationSchema implements KafkaSerializationSchema<Tuple2<String, Integer>> {

@Override
public ProducerRecord<byte[], byte[]> serialize(Tuple2<String, Integer> element, @Nullable Long timestamp) {
    return new ProducerRecord<>(element.f0, element.f1.toString().getBytes());
}

}

然后在使用FlinkKafkaProducer时，传入自定义的MyKafkaSerializationSchema即可——该回答整理自钉群“【③群】Apache Flink China社区”