kafka_test.py

from kafka import KafkaConsumer

host = ''
topic = ''
user = ''
password= ''
sasl_mechanism = 'SCRAM-SHA-512'
security_protocol = 'SASL_SSL'

consumer = KafkaConsumer(
    topic,
    sasl_mechanism = sasl_mechanism,
    security_protocol = security_protocol,
    ssl_cafile='CA.pem',
    sasl_plain_username = user,
    sasl_plain_password = password,
    bootstrap_servers=[host],
    ssl_check_hostname=False
)

for message in consumer:
    value = message.value.decode("utf-8").replace("\\\\", "\\")
    print(f'{message.topic}:{message.partition}:{message.offset}: \
        key={message.key} value={value}')