From d5abe8c50869b22c215e7f2a8d5e28ae2a3e4fd9 Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Wed, 1 Jul 2026 18:31:56 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97=E8=A1=A5=E5=85=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../receiver/listener/RedisStreamConsumer.java   | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
index 07cad5d..1f059eb 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -112,7 +112,7 @@ public class RedisStreamConsumer {
         // 定时统计接收次数
         statsScheduler.scheduleAtFixedRate(() -> {
             long count = receiveCounter.sum();
-            log.info("RedisStreamConsumer receive count={}", count);
+            log.info("[F10] RedisStreamConsumer receive count={}", count);
         }, 10, 10, TimeUnit.SECONDS);
     }
 
@@ -234,7 +234,7 @@ public class RedisStreamConsumer {
         boolean success = false;
         try {
             Map<Object, Object> body = message.getValue();
-            log.info("stream={}, id={}, body={}",
+            log.info("[F10] stream={}, id={}, body={}",
                     message.getStream(),
                     message.getId(),
                     body);
@@ -246,14 +246,14 @@ public class RedisStreamConsumer {
             String jsonParams = gson.toJson(body);
             MyHTTPResponse response = this.defaultHttpRequestUtil.postJson(dataCenterEnvConfig.getF10ApiUrl(), jsonParams);
             if (response.getCode() == 200) {
-                log.info("F10 data sent successfully....");
+                log.info("[F10] F10 data sent successfully: {}", jsonParams);
             } else {
-                log.error("F10 data sent failed....");
+                log.error("[F10] F10 data sent failed....");
             }
 
             success = true;
         } catch (Exception e) {
-            log.error("process error id={}", message.getId(), e);
+            log.error("[F10] process error id={}", message.getId(), e);
         } finally {
             if (success) {
                 ack(stream, message);
@@ -281,9 +281,9 @@ public class RedisStreamConsumer {
                             .withStreamKey(DLQ_STREAM)
             );
             ack(stream, message);
-            log.error("move to DLQ :{}", message);
+            log.error("[F10] move to DLQ :{}", message);
         } catch (Exception e) {
-            log.error("dlq error :{}", message, e);
+            log.error("[F10] dlq error :{}", message, e);
         }
     }
 
@@ -322,7 +322,7 @@ public class RedisStreamConsumer {
                     if (pending.size() < BATCH_SIZE) break;
                 }
             } catch (Exception e) {
-                log.error("reclaim error stream={}", stream, e);
+                log.error("[F10] reclaim error stream={}", stream, e);
             }
         }
     }