I am connecting to a confluent kafka cluster with python clients.The broker side has mtls already set up. I am aiming to connect to the cluster with producer/consumer with the code able to support the authentication.