diff --git a/src/main/java/com/singlestore/debezium/SingleStoreErrorHandler.java b/src/main/java/com/singlestore/debezium/SingleStoreErrorHandler.java
index 1b31213..7cdde40 100644
--- a/src/main/java/com/singlestore/debezium/SingleStoreErrorHandler.java
+++ b/src/main/java/com/singlestore/debezium/SingleStoreErrorHandler.java
@@ -22,4 +22,19 @@ protected Set<Class<? extends Exception>> communicationExceptions() {
         WrongOffsetException.class);
   }
 
+  protected boolean isRetriable(Throwable throwable) {
+    if (throwable instanceof SQLException) {
+      SQLException e = (SQLException) throwable;
+      if (e.getMessage().contains(
+          "The requested Offset is too stale. Please re-start the OBSERVE query from the latest snapshot.")
+          &&
+          e.getErrorCode() == 2851 &&
+          e.getSQLState().equals("HY000")
+      ) {
+        return false;
+      }
+    }
+    
+    return super.isRetriable(throwable);
+  }
 }