From 03b873ebffb7dc1818a460d3aa5339f3a6fd1ef8 Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期二, 07 十一月 2023 23:55:28 +0800
Subject: [PATCH] 增加地磅按钮
---
src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
index 684bdd8..adb141c 100644
--- a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
+++ b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
@@ -6,6 +6,7 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
@@ -34,7 +35,7 @@
String strData = JSONObject.toJSONString(data);
- log.debug("----鎺ㄩ�佺伯鎯呬俊鎭埌浜戠---{}", strData);
+ //log.debug("----鎺ㄩ�佺伯鎯呬俊鎭埌浜戠---{}", strData);
//鎺ㄩ�佷俊鎭�
kafkaTemplate.send("TOPIC_ZLJ_GRAIN_TEMPERATURE", strData).addCallback(success -> {
@@ -45,9 +46,9 @@
// 娑堟伅鍦ㄥ垎鍖哄唴鐨刼ffset
long offset = success.getRecordMetadata().offset();
- log.info("绮儏鎺ㄩ�佹垚鍔�:{}-{}-{}-{}", topic, partition, offset, data.getDeviceID());
+ log.info("---绮儏-->>浜戠鎴愬姛:{}-{}-{}-{}", topic, partition, offset, strData);
}, failure -> {
- log.info("绮儏鎺ㄩ�佸け璐�:{}-{}", data.getDeviceID(), failure.getMessage());
+ log.info("---绮儏-->>浜戠澶辫触:{}-{}", data.getDeviceID(), failure.getMessage());
});
return "SUCCESS";
--
Gitblit v1.9.3