From fe60ec953e3529466c57d93989f37cf775a7d622 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Thomas=20Colin=20de=20Verdi=C3=A8re?=
 <tdeverdiere@iobeya.com>
Date: Tue, 15 Oct 2024 10:11:33 +0200
Subject: [PATCH] Simple fix for #387: return a panic error

---
 pkg/source/adapter/adapter.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pkg/source/adapter/adapter.go b/pkg/source/adapter/adapter.go
index 2dc34eec2..84cf7d8a9 100644
--- a/pkg/source/adapter/adapter.go
+++ b/pkg/source/adapter/adapter.go
@@ -186,6 +186,9 @@ func (a *Adapter) processEntry(ctx context.Context, conn redis.Conn, streamName
 		if !isShuttingDown {
 			time.Sleep(1 * time.Second)
 		}
+		if strings.Contains(strings.ToLower(err.Error()), "use of closed network connection") {
+			panic(err)
+		}
 		return xreadID
 	}