From f8d91d9d09d9225afc02d6c67c005260cf1e8ecf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Far=C3=ADas=20Santana?= Date: Tue, 14 Nov 2023 20:17:32 +0100 Subject: [PATCH] fix: Create ssl context for batch exports kafka producer (#18624) --- posthog/temporal/workflows/logger.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/posthog/temporal/workflows/logger.py b/posthog/temporal/workflows/logger.py index 4c013c82eb86e..6999b7359c91c 100644 --- a/posthog/temporal/workflows/logger.py +++ b/posthog/temporal/workflows/logger.py @@ -10,6 +10,7 @@ from structlog.processors import EventRenamer from structlog.typing import FilteringBoundLogger +from posthog.kafka_client.helper import get_kafka_ssl_context from posthog.kafka_client.topics import KAFKA_LOG_ENTRIES BACKGROUND_LOGGER_TASKS = set() @@ -254,6 +255,7 @@ def __init__( security_protocol=settings.KAFKA_SECURITY_PROTOCOL or "PLAINTEXT", acks="all", api_version="2.5.0", + ssl_context=get_kafka_ssl_context(), ) ) self.logger = structlog.get_logger()