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);
             }
         }
     }