Skip to content

Commit 384aa29

Browse files
aiokafka related fixes
1 parent c057d94 commit 384aa29

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

superclient/util/config.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -230,6 +230,8 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
230230
"security.protocol": "security_protocol",
231231
"sasl.mechanism": "sasl_mechanism",
232232
"ssl.context": "ssl_context",
233+
"sasl.plain.username": "sasl_plain_username",
234+
"sasl.plain.password": "sasl_plain_password",
233235
},
234236
"confluent": {
235237
# Confluent uses Java-style names directly, so most mappings are 1:1

0 commit comments

Comments
 (0)