fixes

Author: idanasulin2706

superclient/agent/interceptor.py

@@ -332,6 +332,9 @@ def __init__(self, conf: Dict[str, Any], *args, **kwargs):
                     if warning_msg:
                         error_msg = warning_msg
 
+                # Store original configuration before applying optimizations
+                orig_cfg = dict(conf)
+                
                 # Apply optimizations to the configuration
                 for k, v in opt_cfg.items():
                     current_val = conf.get(k)
@@ -351,7 +354,7 @@ def __init__(self, conf: Dict[str, Any], *args, **kwargs):
                     producer=self._producer,
                     bootstrap=bootstrap,
                     client_id=client_id,
-                    orig_cfg=conf,
+                    orig_cfg=orig_cfg,
                     opt_cfg=opt_cfg,
                     report_interval_ms=int(report_interval or _DEFAULT_REPORT_INTERVAL_MS),
                     error=error_msg,  # Store error message in tracker

superclient/util/config.py

@@ -100,6 +100,7 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
         "enable.ssl.certificate.verification",
         "ssl.certificate.location", "ssl.certificate.pem",
         "ssl.ca.location", "ssl.ca.pem",
+        "ssl.key.location",
         "ssl.ca.certificate.stores", "ssl.crl.location",
         "ssl.providers", "ssl.context",
         "ssl.cafile", "ssl.certfile", "ssl.keyfile",
@@ -269,6 +270,16 @@ def copy_client_configuration_properties(src: Dict[str, Any], dst: Dict[str, Any
         "batch.num.messages": "batch.num.messages",
         "compression.codec": "compression.codec",
         "oauth_cb": "oauth_cb",
+        
+        # SSL properties (confluent uses Java-style names directly)
+        "ssl.ca.location": "ssl.ca.location",
+        "ssl.certificate.location": "ssl.certificate.location",
+        "ssl.key.location": "ssl.key.location",
+        "ssl.keystore.location": "ssl.keystore.location",
+        "ssl.keystore.password": "ssl.keystore.password",
+        "ssl.key.password": "ssl.key.password",
+        "ssl.endpoint.identification.algorithm": "ssl.endpoint.identification.algorithm",
+        "enable.ssl.certificate.verification": "enable.ssl.certificate.verification",
     }
 }