feat: Add special handling for redis.Nil errors in fetchTask method

Author: laojianzi

redis.go

@@ -3,6 +3,8 @@ package redisdb
 import (
 	"context"
 	"encoding/json"
+	"errors"
+	"fmt"
 	"strings"
 	"sync"
 	"sync/atomic"
@@ -110,7 +112,14 @@ func (w *Worker) fetchTask() {
 			Block: w.opts.blockTime,
 		}).Result()
 		if err != nil {
-			w.opts.logger.Errorf("error while reading from redis %v", err)
+			workerInfo := fmt.Sprintf("{streamName: %q, group: %q, consumer: %q}",
+				w.opts.streamName, w.opts.group, w.opts.consumer)
+			if errors.Is(err, redis.Nil) {
+				w.opts.logger.Infof("no data while reading from redis stream %s", workerInfo)
+			} else {
+				w.opts.logger.Errorf("error while reading from redis %s %v", workerInfo, err)
+			}
+
 			continue
 		}
 		// we have received the data we should loop it and queue the messages