refactor: Remove commented debug statements in kafka_utils.py (#43)

microsoft · Jul 23, 2024 · d5cd8e9 · d5cd8e9
1 parent 627bd4a
commit d5cd8e9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/pwr_studio/kafka_utils.py b/lib/pwr_studio/kafka_utils.py
@@ -110,7 +110,7 @@ def __init__(self, bootstrap_servers: str,
                 'auto.offset.reset': auto_offset_reset,
                 ** consumer_config
             }
-        print("consumer config", self.consumer_config)
+        # print("consumer config", self.consumer_config)
         self.consumer = Consumer(self.consumer_config)
         self.subscribed=False
         self.subscribed_topics = []
@@ -132,7 +132,7 @@ def from_env_vars(group_id: str, auto_offset_reset: str):
         consumer_password = os.getenv('KAFKA_CONSUMER_PASSWORD')
 
         print("Consumer from env vars")
-        print(kafka_broker, use_sasl, consumer_username, consumer_password)
+        # print(kafka_broker, use_sasl, consumer_username, consumer_password)
 
         if type(use_sasl) == str and use_sasl.lower() == 'true':
             return KafkaConsumer(kafka_broker,