этой библиотекой подключатся к Кафка. В методе KafkaClient есть hosts, но нет ни механизма, ни протокола и даже логин\пароль отсутствует.
Все эти параметры можно указывать только в Consumer и Producer, но как тогда делать list_topics, list_acl и тп?
ПС: библиотеки confluent_kafka и kafka-python нормально с этим работают. Просто интересно как работать с pykafka.
Вот же, getting started, SslConfig? https://pykafka.readthedocs.io/en/latest/
Обсуждают сегодня