bugfix - parsing the BS servers

Author: idanasulin2706

.idea/runConfigurations/kafka_clients_example.xml

@@ -29,8 +29,10 @@ public class KafkaProducerExample {
     public static void main(String[] args) {
         // Build the configuration map first using a mutable map
         Map<String, Object> mutableProps = new java.util.HashMap<>();
-        mutableProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, DEFAULT_BOOTSTRAP_SERVERS);
-        mutableProps.put(ProducerConfig.CLIENT_ID_CONFIG, CLIENT_ID);
+//        mutableProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, DEFAULT_BOOTSTRAP_SERVERS);
+//         mutableProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, Arrays.asList(DEFAULT_BOOTSTRAP_SERVERS));
+        mutableProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, List.of(DEFAULT_BOOTSTRAP_SERVERS));
+//        mutableProps.put(ProducerConfig.CLIENT_ID_CONFIG, CLIENT_ID);
         mutableProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         mutableProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         mutableProps.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, COMPRESSION_TYPE);
@@ -42,7 +44,6 @@ public static void main(String[] args) {
 
         // Pass the immutable map directly to the KafkaProducer constructor
         Producer<String, String> producer = new KafkaProducer<String, String>(mutableProps);
-
         long recordCount = 50; // Number of messages to send
         try {
             while (true) {

.idea/runConfigurations/spring_example.xml

@@ -4,7 +4,7 @@
   <groupId>ai.superstream</groupId>
   <artifactId>superstream-clients</artifactId>
   <name>Superstream Kafka Client Optimizer</name>
-  <version>1.0.17</version>
+  <version>1.0.18</version>
   <description>A Java library that dynamically optimizes Kafka client configuration based on recommendations</description>
   <url>https://github.com/superstreamlabs/superstream-clients-java</url>
   <developers>

examples/kafka-clients-example/src/main/java/ai/superstream/examples/KafkaProducerExample.java

@@ -6,7 +6,7 @@
 
     <groupId>ai.superstream</groupId>
     <artifactId>superstream-clients</artifactId>
-    <version>1.0.17</version>
+    <version>1.0.18</version>
     <packaging>jar</packaging>
 
     <name>Superstream Kafka Client Optimizer</name>

superstream-clients/dependency-reduced-pom.xml

@@ -1127,5 +1127,34 @@ public synchronized void putAll(java.util.Map<?,?> m) {
                 put(e.getKey(), e.getValue());
             }
         }
+
+        @Override
+        public String getProperty(String key) {
+            Object value = backing.get(key);
+            if (value == null) {
+                return super.getProperty(key);
+            }
+            
+            // Handle special case for bootstrap.servers which can be any Collection<String>
+            if ("bootstrap.servers".equals(key) && value instanceof java.util.Collection) {
+                try {
+                    @SuppressWarnings("unchecked")
+                    java.util.Collection<String> serverCollection = (java.util.Collection<String>) value;
+                    return String.join(",", serverCollection);
+                } catch (ClassCastException e) {
+                    // If the collection doesn't contain strings, fall back to toString()
+                    logger.debug("bootstrap.servers collection contains non-String elements, falling back to toString()");
+                }
+            }
+            
+            // For all other cases, convert to String
+            return value.toString();
+        }
+
+        @Override
+        public String getProperty(String key, String defaultValue) {
+            String result = getProperty(key);
+            return result != null ? result : defaultValue;
+        }
     }
 }