create_ssl_context¶

kafkit.ssl.create_ssl_context(*, cluster_ca_path: pathlib.Path, client_cert_path: pathlib.Path, client_key_path: pathlib.Path) → ssl.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