如何将KafkaAvroSerializer传入Kafka ProducerRecord？

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>5.5.1</version>
</dependency>

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092,kafka-broker2:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
props.put("schema.registry.url", "http://schema-registry:8081");

KafkaProducer<String, GenericRecord> producer = new KafkaProducer<>(props);

String topic = "my-topic";
String key = "key1";
GenericRecord value = new GenericData.Record(schema); // 假设schema是你定义的Avro Schema
value.put("field1", "value1");
value.put("field2", "value2");

ProducerRecord<String, GenericRecord> record = new ProducerRecord<>(topic, key, value);

producer.send(record, new Callback() {
    public void onCompletion(RecordMetadata metadata, Exception exception) {
        if (exception != null) {
            // 发送失败的处理逻辑
        } else {
            // 发送成功的处理逻辑
        }
    }
});