たくさんのメッセージをkafkaのどうやって送る

Kafkaでは、メッセージを送信するためにプロデューサーのsendメソッドを使用できます。メッセージをまとめて送信する方法は次のとおりです。

1. 送信
2. プロデューサーレコード
3. お届けする

List<ProducerRecord<String, String>> records = new ArrayList<>();
records.add(new ProducerRecord<>("topic", "key1", "value1"));
records.add(new ProducerRecord<>("topic", "key2", "value2"));
records.add(new ProducerRecord<>("topic", "key3", "value3"));

for (ProducerRecord<String, String> record : records) {
    producer.send(record).get(); // 同步发送
}

1. 送信する
2. プロデューサーレコード
3. 送る

List<ProducerRecord<String, String>> records = new ArrayList<>();
records.add(new ProducerRecord<>("topic", "key1", "value1"));
records.add(new ProducerRecord<>("topic", "key2", "value2"));
records.add(new ProducerRecord<>("topic", "key3", "value3"));

for (ProducerRecord<String, String> record : records) {
    producer.send(record, new Callback() {
        @Override
        public void onCompletion(RecordMetadata metadata, Exception exception) {
            if (exception != null) {
                exception.printStackTrace();
            } else {
                System.out.println("Message sent successfully: " + metadata);
            }
        }
    });
}

以上の2つが一般的な大量メッセージ送信方法であり、実情に応じて適宜な方法をお選びいただけます。