From 89db2f3b5098908a239a9302034f8adea029fa4a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Far=C3=ADas=20Santana?= Date: Wed, 8 Nov 2023 18:50:08 +0100 Subject: [PATCH] fix: Connect to kafka in localhost --- posthog/temporal/tests/batch_exports/test_logger.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/posthog/temporal/tests/batch_exports/test_logger.py b/posthog/temporal/tests/batch_exports/test_logger.py index 16dfa29ea1910..e39ffa5d4915f 100644 --- a/posthog/temporal/tests/batch_exports/test_logger.py +++ b/posthog/temporal/tests/batch_exports/test_logger.py @@ -71,7 +71,7 @@ class CaptureKafkaProducer(aiokafka.AIOKafkaProducer): """A test aiokafka.AIOKafkaProducer that captures calls to send_and_wait.""" def __init__(self, *args, **kwargs): - super().__init__(*args, **kwargs) + super().__init__(bootstrap_servers="localhost:9092") self.entries = [] async def send(self, topic, value=None, key=None, partition=None, timestamp_ms=None, headers=None):