lib/kafkr.rb in kafkr-0.13.0 vs lib/kafkr.rb in kafkr-0.18.0

@@ -73,19 +73,10 @@
       current_environment == "production"
     end
 
     def write(message, unique_id = nil)
       begin
-        unique_id ||= SecureRandom.uuid
-      rescue => e
-        unique_id = "unknown"
-        @logger.error("Failed to generate UUID: #{e.message}")
-      end
-      formatted_message = "[#{unique_id}] #{message}"
-
-      begin
-        puts formatted_message if development?
-        logger.info(formatted_message)
+        logger.info(message)
       rescue IOError => e
         @logger.error("Failed to write log: #{e.message}")
       end
     end