From dd08255e8d1463ef0b543a9a26a0126714f0a94f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B0=A2=E6=AC=A3=E6=82=A6?= <2289014031@qq.com> Date: Sun, 29 Sep 2024 10:24:50 +0800 Subject: [PATCH] =?UTF-8?q?Kafka=E7=94=9F=E4=BA=A7=E8=80=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/muyu/car/Kafka.java | 44 +++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java new file mode 100644 index 0000000..d1a0ac1 --- /dev/null +++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java @@ -0,0 +1,44 @@ +package com.muyu.car; + +import com.alibaba.fastjson.JSONObject; +import org.apache.kafka.clients.producer.KafkaProducer; +import org.apache.kafka.clients.producer.Producer; +import org.apache.kafka.clients.producer.ProducerRecord; + +import java.util.Properties; +import java.util.UUID; + +public class Kafka { + public static void main(String[] args) { + //配置kafka生产者 + Properties properties = new Properties(); + properties.put("bootstrap.servers", "http://49.235.108.160:9092"); + properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); + properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); + //创建kafka生产者 + Producer product = new KafkaProducer<>(properties); + String aa = "2345678"; + JSONObject jsonObject = new JSONObject(); + jsonObject.put("aa", aa); + String jsonString = jsonObject.toString(); + System.out.println("JSON内容是:" + jsonString); + try { + product.send(new ProducerRecord<>("nima", UUID.randomUUID().toString(), jsonString + )); + System.out.println("消费的数据内容为:" + jsonString); + } catch (Exception exception) { + exception.printStackTrace(); + } finally { + product.close(); + } + } + + + + + + + + + +}