Fix #387 Panic if Redis client returns use of closed network connection

knative-extensions · Oct 21, 2024 · 8eb7743 · 8eb7743
1 parent 4fd4e47
commit 8eb7743
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/source/adapter/adapter.go b/pkg/source/adapter/adapter.go
@@ -183,6 +183,9 @@ func (a *Adapter) processEntry(ctx context.Context, conn redis.Conn, streamName
 	reply, err := conn.Do("XREADGROUP", "GROUP", groupName, consumerName, "COUNT", count, "BLOCK", blockms, "STREAMS", streamName, xreadID)
 	if err != nil {
 		a.logger.Error("Cannot read from stream", zap.Error(err))
+		if strings.Contains(strings.ToLower(err.Error()), "use of closed network connection") { // Redis has probably been shut down
+			panic("Redis has been shut down")
+		}
 		if !isShuttingDown {
 			time.Sleep(1 * time.Second)
 		}