Блог

Я хочу настроить потребителя кафки (используя python), который подключается к удаленному брокеру кафки. Но для этого требуется проверка подлинности kerberos.

Итак, из того, что я понял, мне необходимо иметь jaas.conf и krb5.conf

ниже приведен мой фрагмент кода

 from kafka import KafkaConsumer  consumer = KafkaConsumer(bootstrap_servers=brokers, group_id='group_id', auto_offset_reset='earliest',  security_protocol='SASL_PLAINTEXT', sasl_mechanism='GSSAPI', sasl_kerberos_service_name='kafka')  

но я не уверен, как и куда поместить jaas и krb5

Я читал, что мне нужно установить их как

 -Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf -Djava.security.krb5.conf=/etc/kafka/krb5.conf  

но если я правильно понимаю, это относится к серверу кафки (а не к клиенту-потребителю). если мне действительно нужно установить как jaas, так и krb5, как я должен это сделать как потребитель?

поскольку я не знаком с kerberos, кажется, что я беру биты информации отовсюду и пришел к неправильному выводу. Любая помощь будет очень признательна!