Pat
Esteemed Contributor

Hi @Suresh_Ulhasnag ,

Yes it's supported. You can have a look at my github repo: https://github.com/cloud-data-engineer/data/blob/main/dlt_telco/docs/README.md

In bronze layer I am connecting to Confluent Kafka: https://github.com/cloud-data-engineer/data/blob/main/dlt_telco/src/bronze.py
You can see example setup there, i.e.:

# Configure Kafka security options
KAFKA_SECURITY_OPTIONS = {
    "kafka.security.protocol": "SASL_SSL",
    "kafka.sasl.mechanism": "PLAIN",
    "kafka.sasl.jaas.config": f"org.apache.kafka.common.security.plain.PlainLoginModule required username='{api_key}' password='{api_secret}';",
}

View solution in original post