Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Authentification error while connecting to kafka broker with kerberos

Highlighted

Authentification error while connecting to kafka broker with kerberos

New Contributor

Hello

I'm using kerberos with lib "confluent_kafka_python" . So, i get this issue while running my code :

SASL authentication failure: Disconnected

and my code is :

from time import sleep from time import sleep from json import dumps #from kafka import KafkaProducer from confluent_kafka import Producer import logging logging.basicConfig(level=logging.DEBUG) p= Producer({ 'bootstrap.servers': '..........', 'sasl.kerberos.principal': 'svchdp-admin@AP.CDC.FR', 'sasl.kerberos.keytab': '/etc/security/keytabs/svchdp-admin.keytab', 'sasl.kerberos.service.name': 'kafka', 'security.protocol': 'SASL_PLAINTEXT', 'sasl.mechanisms': 'GSSAPI', 'debug': 'security' })