From eb11971f308fc3360721dd35190da149f1e68a60 Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Mon, 14 Oct 2024 18:35:54 -0600 Subject: [PATCH] Merge pull request #789 from sbuliarca/errgroupsession-export-err kgo: export the wrapped error from ErrGroupSession --- pkg/kgo/errors.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/kgo/errors.go b/pkg/kgo/errors.go index 3ff1dbfe..9af0c81c 100644 --- a/pkg/kgo/errors.go +++ b/pkg/kgo/errors.go @@ -311,11 +311,11 @@ func (e *errUnknownCoordinator) Error() string { // consumer group member was kicked from the group or was never able to join // the group. type ErrGroupSession struct { - err error + Err error } func (e *ErrGroupSession) Error() string { - return fmt.Sprintf("unable to join group session: %v", e.err) + return fmt.Sprintf("unable to join group session: %v", e.Err) } -func (e *ErrGroupSession) Unwrap() error { return e.err } +func (e *ErrGroupSession) Unwrap() error { return e.Err }