diff --git a/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/helper/ConvertUtils.java b/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/helper/ConvertUtils.java
index 01bbb65c5ce7ddd94086f70317f362389ec13162..6755b885cf1a75ce2671d4d12d27209f4eeda802 100644
--- a/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/helper/ConvertUtils.java
+++ b/starters/starrocks-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/starrocks/helper/ConvertUtils.java
@@ -20,6 +20,10 @@ public class ConvertUtils {
 
     public static <Target> Target convertTo(ConsumerRecord<String, String> record, Class<Target> targetType) {
         CanalChangedEvent event = JacksonUtils.getObjectFromJson(record.value(), CanalChangedEvent.class);
+        return convertTo(event, targetType);
+    }
+
+    public static <Target> Target convertTo(CanalChangedEvent event, Class<Target> targetType) {
         if (event == null) {
             throw new BaseException("CanalChangedEvent is null");
         }