12 lines
296 B
Python
12 lines
296 B
Python
from pathlib import Path
|
|
|
|
from aiokafka.helpers import create_ssl_context
|
|
|
|
from constants import KAFKA_CERTS_PATH
|
|
|
|
context = create_ssl_context(
|
|
cafile=KAFKA_CERTS_PATH / Path('ca-cert'),
|
|
certfile=KAFKA_CERTS_PATH / Path('cert-signed'),
|
|
keyfile=KAFKA_CERTS_PATH / Path('cert-key'),
|
|
)
|