From 3735e4475c27f709584850631330be2cc2f20f6d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Far=C3=ADas=20Santana?= Date: Wed, 15 Nov 2023 09:55:28 +0100 Subject: [PATCH] fix: Use sasl_params instead of ssl context for batch exports logger (#18630) fix: Use sasl_params instead of ssl context --- posthog/temporal/workflows/logger.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/posthog/temporal/workflows/logger.py b/posthog/temporal/workflows/logger.py index 6999b7359c91c..93d1900e5b128 100644 --- 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()