如何将Avro格式的数据从Flink写入Kafka？

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;
import org.apache.flink.streaming.util.serialization.AvroSerializationSchema;

public class AvroToFlinkToKafka {
    public static void main(String[] args) throws Exception {
        // 创建Flink的执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建一个DataStream，包含Avro格式的数据
        DataStream<YourAvroType> avroDataStream = ...;

        // 创建KafkaProducer并将Avro数据写入Kafka
        FlinkKafkaProducer<YourAvroType> kafkaProducer = new FlinkKafkaProducer<>(
                "kafka-broker:9092",  // Kafka的地址
                "your-topic",         // Kafka的topic名称
                new AvroSerializationSchema<>(YourAvroType.class));  // Avro数据的序列化器

        avroDataStream.addSink(kafkaProducer);

        // 执行Flink任务
        env.execute("Write Avro to Kafka");
    }
}