chore: add context to ReadMessage errors (#1199)

segmentio · Oct 2, 2023 · efe02d6 · efe02d6
1 parent 9ecb9d2
commit efe02d6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/reader.go b/reader.go
@@ -790,12 +790,12 @@ func (r *Reader) Close() error {
 func (r *Reader) ReadMessage(ctx context.Context) (Message, error) {
 	m, err := r.FetchMessage(ctx)
 	if err != nil {
-		return Message{}, err
+		return Message{}, fmt.Errorf("fetching message: %w", err)
 	}
 
 	if r.useConsumerGroup() {
 		if err := r.CommitMessages(ctx, m); err != nil {
-			return Message{}, err
+			return Message{}, fmt.Errorf("committing message: %w", err)
 		}
 	}