a_bazu
/
cloud-server-8
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

121

master^2^2
张腾 2024-10-02 10:22:41 +08:00
parent e46b6325c4
commit 903fecc2cc
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java
View File

@ -2,7 +2,6 @@ package com.muyu.server.mqtt;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.muyu.common.kafka.constants.KafkaConstants;
import com.muyu.domain.CarMessage; import com.muyu.domain.CarMessage;
import com.muyu.server.service.CarMessageService; import com.muyu.server.service.CarMessageService;
import jakarta.annotation.PostConstruct; import jakarta.annotation.PostConstruct;
@ -83,7 +82,7 @@ public class Demo {
results[i] = futures.get(i).get(); results[i] = futures.get(i).get();
} }
String jsonString = JSONObject.toJSONString( results ); String jsonString = JSONObject.toJSONString( results );
ProducerRecord<String, String> producerRecord = new ProducerRecord<>( KafkaConstants.KafkaTopic, jsonString); ProducerRecord<String, String> producerRecord = new ProducerRecord<>( "carJsons", jsonString);
kafkaProducer.send(producerRecord); kafkaProducer.send(producerRecord);
} }
// 接收信息 // 接收信息