From caf2599a9869244ded811018811c37a2aabac3fc Mon Sep 17 00:00:00 2001 From: vince <757871790@qq.com> Date: 星期三, 08 一月 2025 11:29:05 +0800 Subject: [PATCH] 优化测温协议 --- src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java index 7aa9969..4b17a11 100644 --- a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java +++ b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java @@ -31,7 +31,7 @@ // 娑堟伅鍦ㄥ垎鍖哄唴鐨刼ffset long offset = success.getRecordMetadata().offset(); - log.info("---鎺ㄩ�佽嚦KAFKA鎴愬姛--:{}-{}-{}-{}", topic, partition, offset, sendData); + log.info("---鎺ㄩ�佽嚦KAFKA鎴愬姛--:{}-{}", topic, sendData); }, failure -> { log.info("---鎺ㄩ�佽嚦KAFKA澶辫触--:{}-{}-{}-{}", topic, sendData); rePublishWithTopic(sendData, topic); -- Gitblit v1.9.3