From d84e2234847b8f92d117ec33ef35683ba5c62c3f Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Wed, 27 Mar 2024 09:09:36 +0800
Subject: [PATCH] =?UTF-8?q?fix(sync):=20=E4=BC=98=E5=8C=96=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E4=BF=A1=E6=81=AF=E6=89=93=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/sync/functions/PulsarMessage2RecordFunction.java    | 2 +-
 .../service/sync/functions/PulsarMessageSourceReader.java       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessage2RecordFunction.java b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessage2RecordFunction.java
index 6ad5425..9c10dd1 100644
--- a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessage2RecordFunction.java
+++ b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessage2RecordFunction.java
@@ -66,7 +66,7 @@ public class PulsarMessage2RecordFunction extends RichMapFunction<String, Record
             if (StrUtil.isNotBlank(opTs) && OPTS_PATTERN.matcher(opTs).matches()) {
                 timestamp = LocalDateTime.parse(opTs, FORMATTER).toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
             } else {
-                throw new Exception("Opts is not match regex " + OPTS_PATTERN.pattern());
+                throw new Exception(StrUtil.format("Opts is not match regex {} value: {}", OPTS_PATTERN.pattern(), opTs));
             }
         } catch (Exception e) {
             logger.error("Parse operation time error", e);
diff --git a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessageSourceReader.java b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessageSourceReader.java
index accd769..2a7dc23 100644
--- a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessageSourceReader.java
+++ b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/PulsarMessageSourceReader.java
@@ -155,7 +155,7 @@ public class PulsarMessageSourceReader extends RichParallelSourceFunction<String
                     }
                 }
             } catch (Throwable t) {
-                logger.error("Read message failure, current value: " + currentValue, t);
+                throw new Exception("Read message failure, current value: " + currentValue, t);
             }
         }
     }