updates

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();