Внедрить OAuth2 в клиентские компоненты Kafka - PullRequest
Новая
       35

Внедрить OAuth2 в клиентские компоненты Kafka

0 голосов
/ 20 января 2020

Я новичок в Кафке. Я пытаюсь настроить SASL / OAUTHBEARER в Кафке. Мне нужна помощь, чтобы понять, как включить эту функцию в клиенте Kafka, например, REST Proxy, и то, что должно быть сквозным потоком, означает, как клиент должен взаимодействовать с брокером Kafka для аутентификации с поставщиком OAuth, поскольку это меня немного не смущает.

Я включил следующие настройки в kafka-rest.properties, чтобы включить его в Restraxy kafka. 

sasl.mechanism=OAUTHBEARER
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;
sasl.login.callback.handler.class=io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler

Когда я пытаюсь свернуться на прокси-kafka-rest, я получаю сообщение об ошибке ниже. 

curl -k GET -H "Content-Type: application/json" https://<ext GW>/topics -H 'api-key: <value>'

Сообщение об ошибке: 

{"error_code":40101,"message":"Client SASL mechanism 'PLAIN' not enabled in the server, enabled mechanisms are [OAUTHBEARER]"}

Не могли бы вы помочь !!

С уважением, Swagatika

...