@@ -80,6 +80,7 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
8080 "ssl.ca.location" , "ssl.ca.pem" ,
8181 "ssl.ca.certificate.stores" , "ssl.crl.location" ,
8282 "ssl.providers" , "ssl.context" ,
83+ "ssl.cafile" , "ssl.certfile" , "ssl.keyfile" ,
8384
8485 # SASL properties
8586 "sasl.mechanism" , "sasl.mechanisms" , "sasl.jaas.config" ,
@@ -92,6 +93,7 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
9293 "sasl.login.refresh.min.period.seconds" , "sasl.login.refresh.buffer.seconds" ,
9394 "sasl.login.retry.backoff.ms" , "sasl.login.retry.backoff.max.ms" ,
9495 "sasl.username" , "sasl.password" ,
96+ "sasl.plain.username" , "sasl.plain.password" ,
9597 "sasl.oauthbearer.config" , "sasl.oauthbearer.client.id" ,
9698 "sasl.oauthbearer.client.secret" , "sasl.oauthbearer.scope" ,
9799 "sasl.oauthbearer.extensions" , "sasl.oauthbearer.token.endpoint.url" ,
@@ -167,11 +169,16 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
167169 "metrics.num.samples" : "metrics_num_samples" ,
168170 "metrics.sample.window.ms" : "metrics_sample_window_ms" ,
169171 "sasl.mechanism" : "sasl_mechanism" ,
172+ "sasl.plain.username" : "sasl_plain_username" ,
173+ "sasl.plain.password" : "sasl_plain_password" ,
170174 "sasl.kerberos.name" : "sasl_kerberos_name" ,
171175 "sasl.kerberos.service.name" : "sasl_kerberos_service_name" ,
172176 "sasl.kerberos.domain.name" : "sasl_kerberos_domain_name" ,
173177 "sasl.oauth.token.provider" : "sasl_oauth_token_provider" ,
174178 "socks5.proxy" : "socks5_proxy" ,
179+ "ssl.cafile" : "ssl_cafile" ,
180+ "ssl.certfile" : "ssl_certfile" ,
181+ "ssl.keyfile" : "ssl_keyfile" ,
175182 },
176183 "aiokafka" : {
177184 # Basic configuration
0 commit comments