fix: Use sasl_params instead of ssl context for batch exports logger (#…

…18630) fix: Use sasl_params instead of ssl context
PostHog · Nov 15, 2023 · 3735e44 · 3735e44
1 parent 6debc1f
commit 3735e44
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/posthog/temporal/workflows/logger.py b/posthog/temporal/workflows/logger.py
@@ -10,7 +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.client import _sasl_params
 from posthog.kafka_client.topics import KAFKA_LOG_ENTRIES
 
 BACKGROUND_LOGGER_TASKS = set()
@@ -255,7 +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(),
+                **_sasl_params(),
             )
         )
         self.logger = structlog.get_logger()