Вам потребуется реализовать два класса, использующих интерфейс с именем AuthenticateCallbackHandler .
Первый класс реализует поток входа в систему, где вам нужно вызвать ваш сервер OAuth для получения токена.Этот класс будет использоваться вашими клиентами или для соединения между брокерами.
Второй класс реализует поток проверки, где вы будете вызывать сервер OAuth, чтобы проверить, является ли токен отправки действительным.Этот класс будет использоваться только в Kafka Broker.
У меня есть пример этой реализации на github.com / jairsjunior / kafka-oauth
Если вы хотите увидетьКак настроить брокера Kafka с помощью этого механизма SASL, есть статья со всеми шагами.https://medium.com/@jairsjunior/how-to-setup-oauth2-mechanism-to-a-kafka-broker-e42e72839fe