SASL_SSL (Authentication( JAAS ) および Authorization) が有効になっている Kafka10 クラスターがあります。以下の小道具でJavaクライアントを使用してSASL経由で接続できます。
ssl.keystore.location="client_keystore.jks"
ssl.keystore.password="password"
ssl.truststore.location="clienttruststore"
ssl.truststore.password="password"
JVM パラメータを介して JAAS conf ファイルを渡します。
-Djava.security.auth.login.config=/path/to/client_jaas.conf
Pythonクライアントで同じことを達成する方法はありますか?