From c70617eb024bff418bf546a18dd8e26305243447 Mon Sep 17 00:00:00 2001 From: Seongmin Lee Date: Tue, 11 Nov 2025 03:46:11 +0900 Subject: [PATCH] wip: fix jetstream client Signed-off-by: Seongmin Lee --- jetstream/jetstream.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 } -- 2.51.2