fix: Create ssl context for batch exports kafka producer (#18624)

PostHog · Nov 14, 2023 · f8d91d9 · f8d91d9
1 parent 0fcd386
commit f8d91d9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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()