大神们，我用flink1.15版本，想在读取kafka的数据前，先给这个流填充一些数据进去，有什么办

大神们，我用flink1.15版本，想在读取kafka的数据前，先给这个流填充一些数据进去，有什么办法吗？感觉没有地方可以先加上一些数据啊？想给dataStream在接收kafka数据前，填充一些数据进去KafkaSource source = KafkaSource. builder() .setBootstrapServers(PropertitesUtil.getConfig("kafka.bootstrap.servers")) .setTopics(PropertitesUtil.getConfig("kafka.yondif.topicname")) .build();

    DataStreamSource<String> dataStream = env.fromSource(source, WatermarkStrategy.noWatermarks(),PropertitesUtil.getConfig("kafka.yondif.topicname"))
            .setParallelism(env.getParallelism());