create_ssl_context¶

kafkit.ssl.create_ssl_context(*, cluster_ca_path: Path, client_cert_path: Path, client_key_path: Path) → SSLContext¶

Create an SSL context for a client connecting to secured Kafka brokers.

Parameters:

cluster_ca_path (pathlib.Path) – Path to the cluster CA certificate.
client_cert_path (pathlib.Path) – Path to the client certificate.
client_key_path (pathlib.Path) – Path to the client key.

Returns:

An SSL context for a Kafka client.

Return type: