在Kafka中，消息可以被保留在缓冲区中以供后续处理。以下是一个使用Java代码示例的解决方法：

1. 创建Kafka生产者配置：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092"); // Kafka服务器地址
props.put("acks", "all"); // 所有副本都接收到消息才认为消息发送成功
props.put("retries", 0); // 消息发送失败的重试次数
props.put("batch.size", 16384); // 缓冲区大小，达到大小后才发送消息
props.put("linger.ms", 1); // 发送消息的延迟时间
props.put("buffer.memory", 33554432); // 缓冲区总大小
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

2. 创建Kafka生产者：

Producer producer = new KafkaProducer<>(props);

3. 发送消息：

producer.send(new ProducerRecord<>("topic-name", "key", "value"));

通过指定batch.size参数，可以控制缓冲区大小。当缓冲区大小达到指定值时，Kafka生产者会批量发送消息。

此外，还可以通过调整linger.ms参数来控制发送消息的延迟时间。如果设置为0，则生产者将立即发送消息。

最后，可以通过调整buffer.memory参数来控制缓冲区的总大小。

请根据您的需求调整这些参数的值。