kafka怎么发送消息

在 Kafka 中，发送消息需要使用生产者（producer）API。具体步骤如下：

1. 创建一个 KafkaProducer 对象。
2. 创建消息对象，可以使用 ProducerRecord 类来创建。
3. 使用 send() 方法将消息发送到 Kafka 集群。

下面是一个使用 Java 语言发送消息的示例代码：

import java.util.Properties;
import org.apache.kafka.clients.producer.*;

public class KafkaProducerExample {
    public static void main(String[] args) {
        // 设置 Kafka 集群的地址
        String bootstrapServers = "localhost:9092";

        // 创建生产者的配置信息
        Properties props = new Properties();
        props.put("bootstrap.servers", bootstrapServers);
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        // 创建生产者对象
        Producer<String, String> producer = new KafkaProducer<>(props);

        // 创建消息对象
        String topicName = "test-topic";
        String key = "test-key";
        String value = "test-value";
        ProducerRecord<String, String> record = new ProducerRecord<>(topicName, key, value);

        // 发送消息
        producer.send(record);

        // 关闭生产者
        producer.close();
    }
}