Confluent_kafka игнорировать параметры SSL в конфигурации ⇐ Python

[Anonymous]

Работа с confluent_kafka, по некоторым причинам я хочу иногда переключать sasl_protocol с SASL_SSL на SASL_PLAINTEXT.
Вопросы такие: я кодирую другой вариант KAFKA_CONFLUENT_SASL_AUTH или могу просто изменить sasl_protocol и все параметры SSL (enable.ssl.certificate.verification, ssl.certificate.location, ssl.key.location) будут игнорироваться confluent_kafka?
простой пример кода:
from confluent_kafka import DeserializingConsumer

sasl_protocol = "SASL_SSL"

KAFKA_CONFLUENT_SASL_AUTH = {
"enable.ssl.certificate.verification": False,
"security.protocol": sasl_protocol,
"sasl.mechanism": "SCRAM-SHA-512",
"sasl.username": "insaneuser",
"sasl.password": "insanepassword",
"bootstrap.servers": "addr1:9093,addr2:9093",
"ssl.certificate.location": settings.NEW_KAFKA_SSL_CERT_LOCATION,
"ssl.key.location": settings.NEW_KAFKA_SSL_KEY_LOCATION,
}

consumer = DeserializingConsumer(
{
"group.id": "mygroup",
"reconnect.backoff.ms": 5000,
"auto.offset.reset": "earliest",
"enable.auto.commit": True,
"session.timeout.ms": 20000,
**KAFKA_CONFLUENT_SASL_AUTH,
}
)
print(consumer.list_topics().topics)


Подробнее здесь: https://stackoverflow.com/questions/792 ... -in-config