From 06a9c47d9b393473ce4c2a4ea0648be805dcd829 Mon Sep 17 00:00:00 2001 From: Sorin Buliarca Date: Wed, 24 Jul 2024 18:45:47 +0300 Subject: [PATCH] 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 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 }