как подключиться к внешнему серверу кафки с помощью файла "cacerts" с помощью python

Question

Я могу подключиться к моему локальному серверу kafka с пакетом python kafka. Однако я не могу подключиться к внешнему серверу Kafka с поддержкой ssl.

Принимая во внимание, что мой Java-код может обмениваться данными с одним и тем же сервером, используя следующие параметры:

props.put("security.protocol", kafkaProtocol);
props.put(SslConfigs.SSL_PROTOCOL_CONFIG, kafkaProtocol);
props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, kafkaCertLocation);
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, kafkaCertPassword);

Я не знаю, какие именно эквивалентные параметры в пакете python kafka. Могут ли некоторые сразу подсказать мне об этом?

Я пробовал этот код:

producer = KafkaProducer(value_serializer=lambda m: json.dumps(m).encode('utf-8'),
                         bootstrap_servers='YYYYY.KAKFASERVER.com:9094',
                         security_protocol='SSL',
                         ssl_certfile='cacerts',
                         ssl_password='xxxxxxx')

Я получаю следующее сообщение об ошибке:

не удалось подключиться к YYYYY.KAKFASERVER.com:9094 неизвестная ошибка (_ssl.c: 3715)