improve logs

Author: idanasulin2706

.idea/runConfigurations/kafka_clients_example.xml

@@ -4,7 +4,7 @@
   <groupId>ai.superstream</groupId>
   <artifactId>superstream-clients</artifactId>
   <name>Superstream Kafka Client Optimizer</name>
-  <version>1.0.204</version>
+  <version>1.0.205</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>

superstream-clients/dependency-reduced-pom.xml

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

superstream-clients/pom.xml

@@ -52,21 +52,23 @@ public Map<String, Object> getOptimalConfiguration(MetadataMessage metadataMessa
             } else {
                 logger.debug(
                         "No matching topic configurations found for the application topics. Applying default optimizations.");
+                logger.warn(
+                        "The topics you're publishing to haven't been analyzed yet. For optimal results, either wait for the next analysis cycle or trigger one manually via the SuperClient Console");
             }
 
             // Apply default optimizations when no matching topics found
             optimalConfiguration = new HashMap<>();
             optimalConfiguration.put("compression.type", "zstd");
-            optimalConfiguration.put("batch.size", 16384); // 16KB
+            optimalConfiguration.put("batch.size", 32768); // 32KB
 
             // Only add linger if not latency-sensitive
             if (!isLatencySensitive) {
                 optimalConfiguration.put("linger.ms", 5000); // 5 seconds default
                 logger.debug(
-                        "Default optimizations will be applied: compression.type=zstd, batch.size=16384, linger.ms=5000");
+                        "Default optimizations will be applied: compression.type=zstd, batch.size=32768, linger.ms=5000");
             } else {
                 logger.debug(
-                        "Default optimizations will be applied: compression.type=zstd, batch.size=16384 (linger.ms unchanged)");
+                        "Default optimizations will be applied: compression.type=zstd, batch.size=32768 (linger.ms unchanged)");
             }
             return optimalConfiguration;
         }

superstream-clients/src/main/java/ai/superstream/core/ConfigurationOptimizer.java

@@ -219,13 +219,25 @@ public boolean optimizeProducer(String bootstrapServers, String clientId, Proper
                     ""
             );
 
-            // Log optimization success with linger.ms status based on environment variable
+            // Log optimization success with appropriate message based on configuration and client ID
             boolean isLatencySensitive = configurationOptimizer.isLatencySensitive();
+            boolean isUsingDefaults = applicationTopics != null && !applicationTopics.isEmpty() && 
+                (metadataMessage.getTopicsConfiguration() == null || 
+                metadataMessage.getTopicsConfiguration().stream().noneMatch(tc -> applicationTopics.contains(tc.getTopicName())));
+            
+            String baseMessage = isUsingDefaults ? 
+                "Successfully optimized producer with default optimization parameters" :
+                "Successfully optimized producer configuration";
+                
+            if (clientId != null && !clientId.trim().isEmpty()) {
+                baseMessage += " for " + clientId;
+            }
+            
             if (isLatencySensitive) {
-                logger.info("Successfully optimized producer configuration for {} (linger.ms left unchanged due to latency sensitivity)", clientId);
-            } else {
-                logger.info("Successfully optimized producer configuration for {}", clientId);
+                baseMessage += " (linger.ms left unchanged due to latency sensitivity)";
             }
+            
+            logger.info(baseMessage);
             return true;
         } catch (Exception e) {
             logger.error("[ERR-030] Failed to optimize producer configuration: {}", e.getMessage(), e);