src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java @@ -22,6 +22,9 @@ public String publishWithTopic(String sendData, String topic) { //推送信息 kafkaTemplate.send(topic, sendData).addCallback(success -> { // 消息发送到的topic
