Merge pull request #10 from superstreamlabs/master

release

Author: idanasulin2706

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "superstream-clients"
-version = "1.0.0"
+version = "1.0.1"
 description = "Superstream optimisation library for Kafka producers"
 authors = [{name = "Superstream Labs", email = "[email protected]"}]
 license = "Apache-2.0"

superclient/agent/interceptor.py

@@ -85,9 +85,9 @@ def init_patch(self, *args, **kwargs):
                 current_val = kwargs.get(k)
                 if current_val != v:
                     if k in kwargs:
-                        logger.debug("Overriding configuration: {} ({} -> {})", k, current_val, v)
+                        logger.info("Overriding configuration: {} ({} -> {})", k, current_val, v)
                     else:
-                        logger.debug("Overriding configuration: {} ((not set) -> {})", k, v)
+                        logger.info("Overriding configuration: {} ((not set) -> {})", k, v)
                     kwargs[k] = v
 
             # Set up reporting interval
@@ -209,9 +209,9 @@ def init_patch(self, *args, **kwargs):
                 current_val = kwargs.get(k)
                 if current_val != v:
                     if k in kwargs:
-                        logger.debug("Overriding configuration: {} ({} -> {})", k, current_val, v)
+                        logger.info("Overriding configuration: {} ({} -> {})", k, current_val, v)
                     else:
-                        logger.debug("Overriding configuration: {} ((not set) -> {})", k, v)
+                        logger.info("Overriding configuration: {} ((not set) -> {})", k, v)
                     kwargs[k] = v
             report_interval = metadata.get("report_interval_ms") if metadata else _DEFAULT_REPORT_INTERVAL_MS
             tr = ProducerTracker(
@@ -437,9 +437,9 @@ def __init__(self, conf: Dict[str, Any], *args, **kwargs):
                     current_val = conf.get(k)
                     if current_val != v:
                         if k in conf:
-                            logger.debug("Overriding configuration: {} ({} -> {})", k, current_val, v)
+                            logger.info("Overriding configuration: {} ({} -> {})", k, current_val, v)
                         else:
-                            logger.debug("Overriding configuration: {} ((not set) -> {})", k, v)
+                            logger.info("Overriding configuration: {} ((not set) -> {})", k, v)
                         conf[k] = v