kafka发送消息的几种方式

Kafka是近年来非常流行的分布式消息系统，使用Kafka可以让应用程序之间以异步的方式传递消息，从而实现解耦、扩展和高可靠性等优点。Kafka的消息发送有几种方式，下面将逐一介绍。

1. 单条发送

最简单的发送方式是单条发送，即一条一条地发送消息。下面是Java代码示例：

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

public class KafkaProducerDemo {
    public static void main(String[] args) {
        String topicName = "mytopic";
        KafkaProducer<String, String> producer = new KafkaProducer<>(getKafkaProps());
        String message = "Hello Kafka!";
        producer.send(new ProducerRecord<>(topicName, message));
        producer.close();
    }

    private static Properties getKafkaProps() {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        return props;
    }
}

2. 批量发送

单条发送的效率比较低，可以采用批量发送的方式提高效率。下面是Java代码示例：

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

import java.util.ArrayList;
import java.util.List;

public class KafkaProducerDemo {
    public static void main(String[] args) {
        String topicName = "mytopic";
        KafkaProducer<String, String> producer = new KafkaProducer<>(getKafkaProps());
        List<ProducerRecord<String, String>> messages = new ArrayList<>();
        messages.add(new ProducerRecord<>(topicName, "message1"));
        messages.add(new ProducerRecord<>(topicName, "message2"));
        messages.add(new ProducerRecord<>(topicName, "message3"));
        producer.send(messages);
        producer.close();
    }

    private static Properties getKafkaProps() {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        return props;
    }
}

3. 异步发送

批量发送会提高效率，但是如果发送的消息量很大，还是会阻塞线程。可以采用异步发送的方式，让发送消息的线程不必等待消息发送结果