From 481f9e3e3b08805e523cb4bf2301d3c2b218876a Mon Sep 17 00:00:00 2001
From: rouchen <3133657697@qq.com>
Date: Wed, 12 Jun 2024 08:41:18 +0800
Subject: [PATCH] =?UTF-8?q?Revert=20"fix=20=E8=BD=A6=E8=BE=86=E6=8A=A5?=
 =?UTF-8?q?=E6=96=87=E6=8E=A8=E9=80=81=E5=88=B0kafka"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

This reverts commit 7225567975063a9c81d1ef3904ccba3cafdd7e92.
---
 src/main/java/com/muyu/web/mqtt/MessageCallbackService.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/muyu/web/mqtt/MessageCallbackService.java b/src/main/java/com/muyu/web/mqtt/MessageCallbackService.java
index 9199582..2115c8f 100644
--- a/src/main/java/com/muyu/web/mqtt/MessageCallbackService.java
+++ b/src/main/java/com/muyu/web/mqtt/MessageCallbackService.java
@@ -34,10 +34,10 @@ public class MessageCallbackService implements MqttCallback {
         String s = new String(mqttMessage.getPayload());
         MessageData main = ConversionUtil.main(s);
         String vin = main.getVin();
-
-        ProducerRecord<String, Object> stringObjectProducerRecord = new ProducerRecord<>("test",main);
+        ProducerRecord<String, String> stringObjectProducerRecord = new ProducerRecord<>(vin,main.toString());
         kafkaTemplate.send(stringObjectProducerRecord);
 
+
     }
 
     @Override