diff --git a/pkg/sasl/plain/plain.go b/pkg/sasl/plain/plain.go index 71198f8c..fbcc2ed0 100644 --- a/pkg/sasl/plain/plain.go +++ b/pkg/sasl/plain/plain.go @@ -3,7 +3,6 @@ package plain import ( "context" - "errors" "github.com/twmb/franz-go/pkg/sasl" ) @@ -52,9 +51,6 @@ func (fn plain) Authenticate(ctx context.Context, _ string) (sasl.Session, []byt type session struct{} -func (session) Challenge(resp []byte) (bool, []byte, error) { - if len(resp) != 0 { - return false, nil, errors.New("unexpected data in plain response") - } +func (session) Challenge([]byte) (bool, []byte, error) { return true, nil, nil }