remove the use of slf4j

Author: idanasulin2706

.idea/runConfigurations/debug_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.3</version>
+  <version>1.0.4</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>
@@ -262,7 +262,6 @@
     <jackson.version>2.14.2</jackson.version>
     <kafka.version>3.3.2</kafka.version>
     <maven.compiler.target>11</maven.compiler.target>
-    <slf4j.version>1.7.36</slf4j.version>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
   </properties>
 </project>

superstream-clients/dependency-reduced-pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>ai.superstream</groupId>
     <artifactId>superstream-clients</artifactId>
-    <version>1.0.3</version>
+    <version>1.0.4</version>
     <packaging>jar</packaging>
 
     <name>Superstream Kafka Client Optimizer</name>
@@ -51,7 +51,6 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <kafka.version>3.3.2</kafka.version>
         <jackson.version>2.14.2</jackson.version>
-        <slf4j.version>1.7.36</slf4j.version>
         <bytebuddy.version>1.14.9</bytebuddy.version>
     </properties>
 
@@ -83,13 +82,6 @@
             <version>${jackson.version}</version>
         </dependency>
 
-        <!-- Logging -->
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-api</artifactId>
-            <version>${slf4j.version}</version>
-        </dependency>
-
         <!-- Test dependencies -->
         <dependency>
             <groupId>org.junit.jupiter</groupId>

superstream-clients/pom.xml

@@ -1,30 +1,15 @@
 package ai.superstream.util;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 /**
  * Custom logger for the Superstream library that falls back to System.out/System.err
- * if no SLF4J implementation is available.
  */
 public class SuperstreamLogger {
     private static final String PREFIX = "superstream";
-    private final Logger logger;
-    private final String loggerName;
-    private static boolean slf4jAvailable = false;
+    private final String className;
     // Flag to control debug logging - default to false to hide debug logs
     private static boolean debugEnabled = false;
 
     static {
-        try {
-            // Try to detect if SLF4J implementation is available
-            Class.forName("org.slf4j.impl.StaticLoggerBinder");
-            slf4jAvailable = true;
-        } catch (ClassNotFoundException e) {
-            System.out.println("[superstream] No SLF4J implementation found. Falling back to System.out logging.");
-            slf4jAvailable = false;
-        }
-
         // Check if debug logging is enabled via system property or environment variable
         String debugFlag = System.getProperty("superstream.debug");
         if (debugFlag == null) {
@@ -39,8 +24,7 @@ public static void setDebugEnabled(boolean enabled) {
     }
 
     private SuperstreamLogger(Class<?> clazz) {
-        this.logger = LoggerFactory.getLogger(clazz);
-        this.loggerName = clazz.getSimpleName();
+        this.className = clazz.getSimpleName();
     }
 
     /**
@@ -64,140 +48,88 @@ private String withPrefix(String message) {
     }
 
     /**
-     * Log an info message with the superstream prefix.
-     *
-     * @param message The message to log
+     * Log an info message.
      */
     public void info(String message) {
-        if (slf4jAvailable) {
-            logger.info(withPrefix(message));
-        } else {
-            System.out.println(loggerName + " INFO: " + withPrefix(message));
-        }
+        System.out.println(formatLogMessage("INFO", message));
     }
 
     /**
-     * Log an info message with parameters and the superstream prefix.
-     *
-     * @param message The message to log
-     * @param args The parameters for the message
+     * Log an info message with parameters.
      */
     public void info(String message, Object... args) {
-        if (slf4jAvailable) {
-            logger.info(withPrefix(message), args);
-        } else {
-            System.out.println(loggerName + " INFO: " + withPrefix(formatMessage(message, args)));
-        }
+        System.out.println(formatLogMessage("INFO", formatArgs(message, args)));
     }
 
     /**
-     * Log a warning message with the superstream prefix.
-     *
-     * @param message The message to log
+     * Log a warning message.
      */
     public void warn(String message) {
-        if (slf4jAvailable) {
-            logger.warn(withPrefix(message));
-        } else {
-            System.out.println(loggerName + " WARN: " + withPrefix(message));
-        }
+        System.out.println(formatLogMessage("WARN", message));
     }
 
     /**
-     * Log a warning message with parameters and the superstream prefix.
-     *
-     * @param message The message to log
-     * @param args The parameters for the message
+     * Log a warning message with parameters.
      */
     public void warn(String message, Object... args) {
-        if (slf4jAvailable) {
-            logger.warn(withPrefix(message), args);
-        } else {
-            System.out.println(loggerName + " WARN: " + withPrefix(formatMessage(message, args)));
-        }
+        System.out.println(formatLogMessage("WARN", formatArgs(message, args)));
     }
 
     /**
-     * Log an error message with the superstream prefix.
-     *
-     * @param message The message to log
+     * Log an error message.
      */
     public void error(String message) {
-        if (slf4jAvailable) {
-            logger.error(withPrefix(message));
-        } else {
-            System.err.println(loggerName + " ERROR: " + withPrefix(message));
-        }
+        System.err.println(formatLogMessage("ERROR", message));
     }
 
     /**
-     * Log an error message with parameters and the superstream prefix.
-     *
-     * @param message The message to log
-     * @param args The parameters for the message
+     * Log an error message with parameters.
      */
     public void error(String message, Object... args) {
-        if (slf4jAvailable) {
-            logger.error(withPrefix(message), args);
-        } else {
-            System.err.println(loggerName + " ERROR: " + withPrefix(formatMessage(message, args)));
-        }
+        System.err.println(formatLogMessage("ERROR", formatArgs(message, args)));
     }
 
     /**
-     * Log an error message with an exception and the superstream prefix.
-     *
-     * @param message The message to log
-     * @param throwable The exception to log
+     * Log an error message with an exception.
      */
     public void error(String message, Throwable throwable) {
-        if (slf4jAvailable) {
-            logger.error(withPrefix(message), throwable);
-        } else {
-            System.err.println(loggerName + " ERROR: " + withPrefix(message));
-            throwable.printStackTrace();
-        }
+        System.err.println(formatLogMessage("ERROR", message));
+        throwable.printStackTrace(System.err);
     }
 
     /**
-     * Log a debug message with the superstream prefix.
-     *
-     * @param message The message to log
+     * Log a debug message.
      */
     public void debug(String message) {
-        // Early return if debug is disabled
-        if (!debugEnabled && !slf4jAvailable) {
-            return;
-        }
-
-        if (slf4jAvailable) {
-            logger.debug(withPrefix(message));
-        } else {
-            System.out.println(loggerName + " DEBUG: " + withPrefix(message));
+        if (debugEnabled) {
+            System.out.println(formatLogMessage("DEBUG", message));
         }
     }
 
     /**
-     * Log a debug message with parameters and the superstream prefix.
-     *
-     * @param message The message to log
-     * @param args The parameters for the message
+     * Log a debug message with parameters.
      */
     public void debug(String message, Object... args) {
-        // Early return if debug is disabled
-        if (!debugEnabled && !slf4jAvailable) {
-            return;
+        if (debugEnabled) {
+            System.out.println(formatLogMessage("DEBUG", formatArgs(message, args)));
         }
+    }
 
-        if (slf4jAvailable) {
-            logger.debug(withPrefix(message), args);
-        } else {
-            System.out.println(loggerName + " DEBUG: " + withPrefix(formatMessage(message, args)));
-        }
+    public static boolean isDebugEnabled() {
+        return debugEnabled;
     }
 
-    private String formatMessage(String message, Object... args) {
-        // Simple implementation of string formatting for fallback mode
+    /**
+     * Format a log message with the Superstream prefix and class name.
+     */
+    private String formatLogMessage(String level, String message) {
+        return String.format("[%s] %s %s: %s", PREFIX, level, className, message);
+    }
+
+    /**
+     * Replace placeholder {} with actual values.
+     */
+    private String formatArgs(String message, Object... args) {
         if (args == null || args.length == 0) {
             return message;
         }
@@ -215,6 +147,4 @@ private String formatMessage(String message, Object... args) {
         }
         return result;
     }
-
-
 }