fix: TAP-9678 StarRocks cache data is incomplete

plugin-kit/tapdata-pdk-api/src/main/java/io/tapdata/pdk/apis/functions/ConnectorFunctions.java

@@ -82,6 +82,12 @@ public class  ConnectorFunctions extends ConnectionFunctions<ConnectorFunctions>
     protected GetStreamOffsetFunction getStreamOffsetFunction;
     protected ExportEventSqlFunction exportEventSqlFunction;
     protected FlushOffsetFunction flushOffsetFunction;
+    protected WriteRecordCallbackFunction writeRecordCallbackFunction;
+
+    public ConnectorFunctions supportWriteRecordCallback(WriteRecordCallbackFunction function) {
+        writeRecordCallbackFunction = function;
+        return this;
+    }
 
     public ConnectorFunctions supportFlushOffsetFunction(FlushOffsetFunction function) {
         flushOffsetFunction = function;
@@ -606,4 +612,8 @@ public ExportEventSqlFunction getExportEventSqlFunction() {
     public FlushOffsetFunction getFlushOffsetFunction() {
         return flushOffsetFunction;
     }
+
+    public WriteRecordCallbackFunction getWriteRecordCallbackFunction() {
+        return writeRecordCallbackFunction;
+    }
 }

plugin-kit/tapdata-pdk-api/src/main/java/io/tapdata/pdk/apis/functions/connector/target/WriteRecordCallbackFunction.java

@@ -0,0 +1,23 @@
+package io.tapdata.pdk.apis.functions.connector.target;
+
+import io.tapdata.entity.event.dml.TapRecordEvent;
+import io.tapdata.entity.schema.TapTable;
+import io.tapdata.pdk.apis.context.TapConnectorContext;
+import io.tapdata.pdk.apis.entity.WriteListResult;
+import io.tapdata.pdk.apis.functions.connector.TapConnectorFunction;
+
+import java.util.List;
+import java.util.function.Consumer;
+
+public interface WriteRecordCallbackFunction extends TapConnectorFunction {
+
+    /**
+     * insert, update, delete events.
+     *
+     * @param connectorContext
+     * @param recordEvents
+     * @param consumer
+     */
+    void writeRecordCallback(TapConnectorContext connectorContext, Consumer<Boolean> consumer) throws Throwable;
+
+}