Kafka-Python Использовать пользовательский модуль входа вместо PlainLoginModule - PullRequest
0 голосов
/ 02 мая 2018

Мы используем kafka-python для подключения к нашим экземплярам Kafka. Чтобы получить доступ к этому, нам нужно пройти аутентификацию, а это не простая аутентификация по имени пользователя / паролю, нам нужно получить access_token из Identity-Service и использовать его для доступа к экземплярам Kafka.

Может кто-нибудь помочь мне с настройкой для этого в kafka-python? Это то же самое, что делать что-то ниже в Java: -

KafkaClient {
  com.mykafka.KafkaIdentityClientLoginModule required;
};

Где KafkaIdentityClientLoginModule - имя пользовательского модуля входа в систему.

Спасибо

Примечание: -

Если есть другая библиотека, которая поддерживает эту аутентификацию, мы открыты для этого.

Ссылки

https://github.com/dpkp/kafka-python

* ** тысяча двадцать-одина * -python.readthedocs.io одна тысячи двадцать-два / о / ведущий / * 1 023 *

...