kafka 生产数据代码

以下是使用Java语言编写的Kafka生产数据的示例代码：

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

public class KafkaProducerExample {
   public static void main(String[] args) throws Exception{
      String topicName = "my_topic"; // 指定要生产消息的主题名称
      String key = "key1"; // 指定消息的键
      String value = "Hello, Kafka!"; // 指定消息的值

      Properties props = new Properties(); // 创建Kafka生产者配置属性对象
      props.put("bootstrap.servers", "localhost:9092"); // 指定Kafka集群的地址
      props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); // 指定键序列化器
      props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); // 指定值序列化器

      KafkaProducer<String, String> producer = new KafkaProducer<>(props); // 创建Kafka生产者实例
      ProducerRecord<String, String> record = new ProducerRecord<>(topicName, key, value); // 创建要发送的消息记录
      producer.send(record); // 发送消息
      producer.close(); // 关闭Kafka生产者实例
   }
}

在代码中，我们首先创建了一个Kafka生产者配置属性对象，并指定了Kafka集群的地址、键和值的序列化器。然后创建一个Kafka生产者实例，并根据指定的主题名称、键和值创建要发送的消息记录。最后，使用Kafka生产者实例发送消息，并关闭生产者实例。