improve logging

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.18</version>
+  <version>1.0.19</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.18</version>
+    <version>1.0.19</version>
     <packaging>jar</packaging>
 
     <name>Superstream Kafka Client Optimizer</name>

superstream-clients/pom.xml

@@ -225,7 +225,7 @@ private void run() {
                 }
                 producer.flush();
             } catch (Exception e) {
-                logger.error("[ERR-022] Cluster stats coordinator failed for {}: {}", bootstrapServers, e.getMessage(), e);
+                logger.error("[ERR-022] Cluster stats coordinator failed for {}, please make sure the Kafka user has read/write/describe permissions on superstream.* topics: {}. Full stack trace:", bootstrapServers, e.getMessage(), e);
             }
         }
     }

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

@@ -78,10 +78,10 @@ public MetadataMessage getMetadataMessage(String bootstrapServers, Properties or
             String json = records.iterator().next().value();
             return objectMapper.readValue(json, MetadataMessage.class);
         } catch (IOException e) {
-            logger.error("[ERR-027] Unable to retrieve optimizations data from Superstream. This is required for optimization. Please contact the Superstream team if the issue persists.");
+            logger.error("[ERR-027] Unable to retrieve optimizations data from Superstream. This is required for optimization. Please contact the Superstream team if the issue persists.", e);
             return null;
         } catch (Exception e) {
-            logger.error("[ERR-028] Unable to retrieve optimizations data from Superstream. This is required for optimization. Please contact the Superstream team if the issue persists.");
+            logger.error("[ERR-028] Unable to retrieve optimizations data from Superstream. This is required for optimization. Please make sure the Kafka user has read/write/describe permissions on superstream.* topics.", e);
             return null;
         }
     }

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

@@ -72,7 +72,7 @@ public static String getHostname() {
             cachedHostname = localHost.getHostName();
             return cachedHostname;
         } catch (UnknownHostException e) {
-            logger.error("[ERR-034] Failed to determine local hostname", e);
+            logger.error("[ERR-091] Failed to determine local hostname", e);
             return "";
         }
     }