diff --git a/src/sf_binlog_writer.h b/src/sf_binlog_writer.h
index 8103869..ed4e803 100644
--- a/src/sf_binlog_writer.h
+++ b/src/sf_binlog_writer.h
@@ -205,6 +205,9 @@ int sf_binlog_writer_notify_exit(SFBinlogWriterInfo *writer);
 #define sf_binlog_writer_set_flags(writer, flags) \
     sf_file_writer_set_flags(&(writer)->fw, flags)
 
+#define sf_binlog_writer_get_last_version_ex(writer, log_level) \
+    sf_file_writer_get_last_version_ex(&(writer)->fw, log_level)
+
 #define sf_binlog_writer_get_last_version(writer) \
     sf_file_writer_get_last_version(&(writer)->fw)
 
diff --git a/src/sf_file_writer.h b/src/sf_file_writer.h
index 2f672a1..dca7753 100644
--- a/src/sf_file_writer.h
+++ b/src/sf_file_writer.h
@@ -88,20 +88,30 @@ static inline void sf_file_writer_set_flags(
     writer->flags = flags;
 }
 
-static inline int64_t sf_file_writer_get_last_version(
-        SFFileWriterInfo *writer)
+static inline int64_t sf_file_writer_get_last_version_ex(
+        SFFileWriterInfo *writer, const int log_level)
 {
     if (writer->flags & SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION) {
         return writer->last_versions.done;
     } else {
-        logError("file: "__FILE__", line: %d, "
-                "writer: %s, should set writer flags to %d!",
-                __LINE__, writer->cfg.subdir_name,
-                SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION);
+        if (FC_LOG_BY_LEVEL(log_level)) {
+            log_it_ex(&g_log_context, log_level,
+                    "file: "__FILE__", line: %d, "
+                    "writer: %s, should set writer flags to %d!",
+                    __LINE__, writer->cfg.subdir_name,
+                    SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION);
+        }
+
         return -1;
     }
 }
 
+static inline int64_t sf_file_writer_get_last_version(
+        SFFileWriterInfo *writer)
+{
+    return sf_file_writer_get_last_version_ex(writer, LOG_ERR);
+}
+
 int sf_file_writer_get_binlog_indexes(const char *data_path,
         const char *subdir_name, int *start_index, int *last_index);