Support Questions
Find answers, ask questions, and share your expertise
Check out our newest addition to the community, the Cloudera Innovation Accelerator group hub.

Who agreed with this topic

How to authenticate (through Kerborized cluster) to kafka using python.

Rising Star



I am trying to connect Kafka from my local machine to kafka kerberized cluster using python, but i am connect with below credentials. Could any guide me and you help is appreciated.

consumer = KafkaConsumer('test',bootstrap_servers='XXX:1234',
   #client_id= kafka-python- + __version__,
   connections_max_idle_ms=9 * 60 * 1000,
   #socket_options= [(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)],
   sock_chunk_bytes=4096, # undocumented experimental option
   sock_chunk_buffer_count=1000, # undocumented experimental option
   #sasl_plain_username= None,
   # metrics configs

for msg in consumer:


Please guide and you help is appreciated.



Who agreed with this topic