Skip to content

Instantly share code, notes, and snippets.

@ns-mkusper

ns-mkusper/kafka_python_sasl_scram.py

Forked from alexlopes/kafka_python_sasl_scram.py
Created January 19, 2023 17:19
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ns-mkusper/da2b9c25479f6c86d015c4deffad3126 to your computer and use it in GitHub Desktop.
Save ns-mkusper/da2b9c25479f6c86d015c4deffad3126 to your computer and use it in GitHub Desktop.
Download ZIP
Kafka Python with SASL/SCRAM Authentication Example
Raw
kafka_python_sasl_scram.py
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)
for msg in consumer:
print (msg)
def produce():
producer = KafkaProducer(security_protocol="SASL_SSL", sasl_mechanism="SCRAM-SHA-512", sasl_plain_username=SASL_USERNAME, sasl_plain_password=SASL_PASSWORD, bootstrap_servers=BOOTSTRAP_SERVERS)
producer.send(TOPIC_NAME, b'some_message_bytes')
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment