diff --git a/redis/redis.go b/redis/redis.go
index aa4e947..c338e75 100644
--- a/redis/redis.go
+++ b/redis/redis.go
@@ -81,7 +81,7 @@ func GetReadStream(ctx context.Context, msg ...QueueMessage) error {
 	return nil
 }
 
-// GetReadFromStream 读取ReadFromStream数据
+// GetReadFromStream  读取ReadFromStream数据
 func GetReadFromStream(ctx context.Context, streamKey, groupName, consumerName string, count, blockMs int64, Block bool, fn func(ctx context.Context, message map[string]interface{}) error) (err error) {
 	glog.Infof(ctx, "初始化 Stream: %s, 消费者组: %s", streamKey, groupName)
 	err = InitStreamGroup(ctx, streamKey, groupName)