SASL/OAUTHBEARER authentication for Kafka 2.0

[ggrcha]

Versions
Sarama Version: cebb584
Kafka Version: 2.0
Go Version: v1.11.1

Problem Description

As said by @mkmkaminski1988 on confluent-kafka-go#247, it would be important to have the OAUTHBEARER mechanism for authentication on Kafka brokers. Today, only Java clients can take advantage of this functionality, as edenhill/librdkafka still doesn't have SASL/OAUTHBEARER.

I'd like to discuss the design of the implementation before forking the project.

Thanks!

(cc @edenhill / @jairsjunior)

[mk6i]

👍

[ggrcha]

Having some issues on this implementation:

• I successfully authenticate via OAUTH and the kafka broker finishes de SASL process (DEBUG Set SASL server state to COMPLETE)

• After that, I have an EOF exception and I can't figure it out what is missing.

While testing de SASL Plain authentication, did anyone got some similar issue?

Thanks.

[mk6i]

@ggrcha Have you had a chance to try out the new SASL/OAUTHBEARER implementation? Thinking we might be able to close this issue.

[ggrcha]

@mkaminski1988 yes I did!!! Great job! It works like a charm :)

Closing the isue.