yangle-wangannan
/
vehicle
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix 车辆报文推送到kafka

master
rouchen 2024-06-10 14:11:14 +08:00
parent dcb15cd9e9
commit 7225567975
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/muyu/mqtt/MessageCallbackService.java
View File

@ -36,9 +36,9 @@ public class MessageCallbackService implements MqttCallback {
String s = new String(mqttMessage.getPayload()); String s = new String(mqttMessage.getPayload());
MessageData main = ConversionUtil.main(s); MessageData main = ConversionUtil.main(s);
String vin = main.getVin(); String vin = main.getVin();
ProducerRecord<String, String> stringObjectProducerRecord = new ProducerRecord<>(vin,main.toString());
kafkaTemplate.send(stringObjectProducerRecord);
ProducerRecord<String, Object> stringObjectProducerRecord = new ProducerRecord<>("test",main);
kafkaTemplate.send(stringObjectProducerRecord);
} }