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()