diff --git a/jetstream/jetstream.go b/jetstream/jetstream.go
index fc4480fd..4de9fcfd 100644
--- a/jetstream/jetstream.go
+++ b/jetstream/jetstream.go
@@ -159,8 +159,9 @@ func (j *JetstreamClient) connectAndRead(ctx context.Context) {
 		j.cancelMu.Unlock()
 
 		if err := j.client.ConnectAndRead(connCtx, cursor); err != nil {
-			l.Error("error reading jetstream", "error", err)
+			l.Error("error reading jetstream, retry in 3s", "error", err)
 			cancel()
+			time.Sleep(3 * time.Second)
 			continue
 		}