diff --git a/pkg/kgo/errors.go b/pkg/kgo/errors.go index 8d574b90..27073b32 100644 --- a/pkg/kgo/errors.go +++ b/pkg/kgo/errors.go @@ -298,11 +298,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 }