From c748a29aeac71e5e969fff90dbbb39c820754f4f Mon Sep 17 00:00:00 2001
From: zhouwentao <1577701412@qq.com>
Date: Tue, 12 Sep 2023 15:11:19 +0800
Subject: [PATCH] updates

---
 .../java/com/example/zxweb/controller/KafkaController.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/example/zxweb/controller/KafkaController.java b/src/main/java/com/example/zxweb/controller/KafkaController.java
index 7768e4e..fff1491 100644
--- a/src/main/java/com/example/zxweb/controller/KafkaController.java
+++ b/src/main/java/com/example/zxweb/controller/KafkaController.java
@@ -169,11 +169,11 @@ public class KafkaController {
         String value = requestBody.getString("value");
         // 创建 KafkaProducer
         KafkaProducer<String, String> producer = new KafkaProducer<>(kafkaUtil.getSafeProducerPro());
-
         // 发送消息
-        ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);
+        ProducerRecord<String, String> record = new ProducerRecord<>(topic,requestBody.toJSONString());
         producer.send(record);
-
+        log.info("-------------------");
+        log.info(record.value());
         // 关闭 KafkaProducer
         producer.close();
         return Result.OK();