kafka 发送数据代码模板

以下是一个简单的 Kafka 发送数据的代码模板：

import java.util.Properties;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;

public class KafkaProducerExample {
    public static void main(String[] args) {
        // 配置 Kafka 生产者属性
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092"); // Kafka 集群地址
        props.put("key.serializer", StringSerializer.class.getName()); // 键的序列化方式
        props.put("value.serializer", StringSerializer.class.getName()); // 值的序列化方式

        // 创建 Kafka 生产者实例
        KafkaProducer<String, String> producer = new KafkaProducer<>(props);

        // 发送消息
        String topic = "test-topic"; // 发送到的主题
        String key = "key1"; // 消息的键
        String value = "hello world"; // 消息的值
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);
        producer.send(record);

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

需要注意的是，这只是一个简单的示例，实际使用中需要根据具体需求进行配置和修改。