From 2bb6092cab12204ba4425a58f29815c66c9c01b1 Mon Sep 17 00:00:00 2001 From: Kumaran Rajendhiran Date: Fri, 24 May 2024 13:18:14 +0530 Subject: [PATCH] Add test to check consumer_logger --- tests/brokers/confluent/test_logger.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/brokers/confluent/test_logger.py b/tests/brokers/confluent/test_logger.py index add2b17e54..ab72676fc5 100644 --- a/tests/brokers/confluent/test_logger.py +++ b/tests/brokers/confluent/test_logger.py @@ -37,9 +37,9 @@ def subscriber(m): async with self.patch_broker(consume_broker) as br: await br.start() - await br.publish_batch(1, "hi", topic=queue) - - # ToDo: Fetch consumer logger and assert it + for sub in br._subscribers.values(): + consumer_logger = sub.consumer.logger + assert consumer_logger == test_logger producer_logger = br._producer._producer.logger assert producer_logger == test_logger