From 903fecc2ccf95e86177734e59d5f54962acd978e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=85=BE?= <3467447354@qq.com> Date: Wed, 2 Oct 2024 10:22:41 +0800 Subject: [PATCH] 121 --- .../src/main/java/com/muyu/server/mqtt/Demo.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java index 007c82e..fa5f209 100644 --- a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java +++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java @@ -2,7 +2,6 @@ package com.muyu.server.mqtt; import com.alibaba.fastjson.JSONObject; -import com.muyu.common.kafka.constants.KafkaConstants; import com.muyu.domain.CarMessage; import com.muyu.server.service.CarMessageService; import jakarta.annotation.PostConstruct; @@ -83,7 +82,7 @@ public class Demo { results[i] = futures.get(i).get(); } String jsonString = JSONObject.toJSONString( results ); - ProducerRecord producerRecord = new ProducerRecord<>( KafkaConstants.KafkaTopic, jsonString); + ProducerRecord producerRecord = new ProducerRecord<>( "carJsons", jsonString); kafkaProducer.send(producerRecord); } // 接收信息