diff --git a/internal/dcs/zk.go b/internal/dcs/zk.go
index 3739339..608ba7d 100644
--- a/internal/dcs/zk.go
+++ b/internal/dcs/zk.go
@@ -277,10 +277,10 @@ func (z *zkDCS) Initialize() {
 func (z *zkDCS) retryRequestInternal(code func() error) error {
 	err := code()
 	if err != zk.ErrConnectionClosed {
-		return nil
+		return backoff.Permanent(err)
 	}
 	if !z.IsConnected() {
-		return nil
+		return backoff.Permanent(err)
 	}
 	return err
 }