Simple fix for knative-extensions#387: return a panic error

tdeverdiere · Oct 15, 2024 · fe60ec9 · fe60ec9
1 parent 4fd4e47
commit fe60ec9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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
 	}