diff --git a/x/stream/service.go b/x/stream/service.go
index 0ce9fc4c..0f90e8d0 100644
--- a/x/stream/service.go
+++ b/x/stream/service.go
@@ -194,7 +194,7 @@ func (s *service) GetRecentItems(ctx context.Context, streams []string, until ti
 			if err != nil {
 				log.Printf("Error: %v", err)
 				span.RecordError(err)
-				return nil, err
+				continue
 			}
 			for stream, chunk := range chunks {
 				items[stream] = chunk