kafkaTemplate.send写入大批量数据

当您需要写入大批量数据时，`kafkaTemplate.send`方法可以进行批量异步发送，以提高性能和效率。

public void sendMessages(List<String> messages, String topic) {
    List<ListenableFuture<SendResult<String, String>>> futures = new ArrayList<>();
    for (String message : messages) {
        ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send(topic, message);
        futures.add(future);
    }
    ListenableFutureUtils.successfulListenableFuture(null)
            .completable()
            .thenCombineAll(futures)
            .join();
}

在上述代码中，我们使用了`ListenableFutureUtils.successfulListenableFuture(null)`来创建一个已完成的`ListenableFuture`对象。然后，我们将每个发送操作的`ListenableFuture`对象添加到`futures`列表中。最后，我们使用`thenCombineAll`方法将所有`ListenableFuture`对象进行组合，并使用`join`方法等待所有消息发送完成。

请注意，上述代码示例中使用的是异步发送方式。这意味着发送操作将在后台线程中进行，并不会阻塞当前线程。如果您需要同步发送方式，请使用`get()`方法等待每个发送操作完成。

另外，确保您已经正确配置和初始化了`kafkaTemplate`实例，以便与Kafka集群进行通信。同时，根据您的具体需求和Kafka集群的配置，可能需要进行适当的调优和优化。