Kafka如何在同一请求中发送多批数据？

Kafka 提供了一种批处理机制，可以在同一请求中发送多批数据。这可以通过设置 ProducerConfig 中的 batch.size 和 linger.ms 参数来实现，如下所示：

// 设置批处理的大小，以字节为单位，默认值为 16384
props.put("batch.size", 32768);
// 设置发送前的最大等待时间，以毫秒为单位，默认值为 0（即立即发送）
props.put("linger.ms", 10);
Producer<String, String> producer = new KafkaProducer<>(props);

在这个例子中，我们设置批处理大小为 32768 字节，并将等待时间设置为 10 毫秒。这意味着在一个请求中，当积累的数据量达到 32768 字节或者等待时间达到 10 毫秒时，批处理将被发送。

如果您想要在同一个请求中发送多个批次，只需要在 ProducerRecord 中使用相同的分区和键来发送多个消息即可，如下所示：

ProducerRecord<String, String> record1 = new ProducerRecord<>("my_topic", "partition_1", "key1", "value1");
ProducerRecord<String, String> record2 = new ProducerRecord<>("my_topic", "partition_1", "key2", "value2");
producer.send(record1);
producer.send(record2);

在这个例子中，我们使用相同的分区名和键来发送两个消息 record1 和 record2，这将在同一请求中作为两批数据发送。

总之，通过设置适当的批处理大小和等待时间，您可以轻松地实现在同一请求中发送多批数据的需求。