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