Merge pull request #289 from j3-signalroom/288-if-use_kafka_writertrue-the-schema-registry-info-is-not-being-retrieved-properly

Resolved #288.

Author: j3-signalroom

CHANGELOG.md

@@ -12,6 +12,7 @@ The format is base on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 
 ### Fixed
 - Issue [#285](https://github.com/j3-signalroom/kafka_cluster-topics-partition_count_recommender-tool/issues/285)
+- Issue [#288](https://github.com/j3-signalroom/kafka_cluster-topics-partition_count_recommender-tool/issues/288)
 
 ## [0.12.04.000] - 2025-10-14
 ### Changed

CHANGELOG.pdf

@@ -168,9 +168,9 @@ def main():
         if use_confluent_cloud_api_key_to_fetch_resource_credentials:
             # Read the Schema Registry credentials using Confluent Cloud API key
             sr_credentials = fetch_schema_registry_via_confluent_cloud_api_key(principal_id, 
-                                                                            metrics_config, 
-                                                                            use_private_schema_registry, 
-                                                                            environment_filter)
+                                                                               metrics_config, 
+                                                                               use_private_schema_registry, 
+                                                                               environment_filter)
         else:
             # Read the Schema Registry credentials from the environment variable or AWS Secrets Manager
             sr_credentials = fetch_schema_registry_credentials_via_env_file(use_aws_secrets_manager)
@@ -223,7 +223,7 @@ def main():
     if len(kafka_credentials) == 1:
         # Single Kafka cluster.  No need for cluster-level threading
         if use_kafka_writer:
-            success = _analyze_kafka_cluster(kafka_credentials[0], config, sr_credential=sr_credentials[0])
+            success = _analyze_kafka_cluster(kafka_credentials[0], config, sr_credential=sr_credentials[kafka_credentials[0]["environment_id"]])
         else:
             success = _analyze_kafka_cluster(kafka_credentials[0], config)