Skip to content

Commit efe02d6

Browse files
authored
chore: add context to ReadMessage errors (#1199)
1 parent 9ecb9d2 commit efe02d6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

reader.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -790,12 +790,12 @@ func (r *Reader) Close() error {
790790
func (r *Reader) ReadMessage(ctx context.Context) (Message, error) {
791791
m, err := r.FetchMessage(ctx)
792792
if err != nil {
793-
return Message{}, err
793+
return Message{}, fmt.Errorf("fetching message: %w", err)
794794
}
795795

796796
if r.useConsumerGroup() {
797797
if err := r.CommitMessages(ctx, m); err != nil {
798-
return Message{}, err
798+
return Message{}, fmt.Errorf("committing message: %w", err)
799799
}
800800
}
801801

0 commit comments

Comments
 (0)