在apache kafka中合并post请求

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

public class KafkaPostRequestMerger {
    private KafkaProducer<String, String> producer;

    public KafkaPostRequestMerger() {
        // 初始化Kafka Producer
        Properties props = new Properties();
        props.put("bootstrap.servers", "kafka-broker1:9092,kafka-broker2:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        producer = new KafkaProducer<>(props);
    }

    public void mergePostRequests(List<String> requests, String topic) {
        // 合并POST请求并发送到Kafka集群
        StringBuilder mergedRequest = new StringBuilder();
        for (String request : requests) {
            mergedRequest.append(request);
        }
        producer.send(new ProducerRecord<>(topic, mergedRequest.toString()));
    }

    public void close() {
        // 关闭Kafka Producer
        producer.close();
    }
}