Oscar Adolfo Martinez Russi omartinez-vmd

alexlopes / kafka_python_sasl_scram.py

Last active December 25, 2024 10:37

Kafka Python with SASL/SCRAM Authentication Example

	import os
	from kafka import KafkaProducer, KafkaConsumer

	BOOTSTRAP_SERVERS=os.gentenv("KAFKA_BOOTSTRAP_SERVERS").split(",")
	TOPIC_NAME="the-topic"
	SASL_USERNAME=os.gentenv("KAFKA_SASL_USERNAME")
	SASL_PASSWORD=os.gentenv("KAFKA_SASL_PASSWORD")

	def consume():
	consumer = KafkaConsumer(TOPIC_NAME, security_protocol="SASL_SSL", sasl_mechanism="SCRAM-SHA-512", sasl_plain_username=SASL_USERNAME, sasl_plain_password=SASL_PASSWORD, bootstrap_servers=BOOTSTRAP_SERVERS)