如何使用spring boot app中的li-apache- Kafka -client从Kafka producer发送大消息(1MB以上)？

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

public class KafkaMessageSender {
    private KafkaProducer<String, byte[]> producer;

    public KafkaMessageSender() {
        // 配置Kafka Producer
        Properties props = new Properties();
        props.put("bootstrap.servers", "kafka-server:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
        producer = new KafkaProducer<>(props);
    }

    public void sendMessage(String topic, byte[] message) {
        // 创建ProducerRecord并发送消息
        ProducerRecord<String, byte[]> record = new ProducerRecord<>(topic, message);
        producer.send(record);
    }
}