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

Authentification error while connecting to kafka broker with kerberos

Explorer

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' })

Don't have an account?
Coming from Hortonworks? Activate your account here