fix: Connect to kafka in localhost

PostHog · Nov 8, 2023 · 37bef65 · 37bef65
1 parent 19b697d
commit 37bef65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):