Refactor: Reapply @Slf4j cleanup for Azure plugin classes

src/main/java/io/kestra/plugin/azure/datafactory/CreateRun.java

@@ -32,7 +32,7 @@
 import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
+
 import org.slf4j.Logger;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -50,7 +50,6 @@
 import java.util.concurrent.atomic.AtomicReference;
 
 
-@Slf4j
 @SuperBuilder
 @ToString
 @EqualsAndHashCode

src/main/java/io/kestra/plugin/azure/eventhubs/Consume.java

@@ -33,9 +33,9 @@
 import lombok.NoArgsConstructor;
 import lombok.ToString;
 import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
 import org.slf4j.Logger;
 
+
 import java.io.BufferedOutputStream;
 import java.io.File;
 import java.io.FileOutputStream;
@@ -79,7 +79,6 @@
 @Schema(
     title = "Consume events from Azure Event Hubs."
 )
-@Slf4j
 @SuperBuilder
 @NoArgsConstructor
 @Getter

src/main/java/io/kestra/plugin/azure/eventhubs/EventHubConsumerInterface.java

@@ -1,12 +1,10 @@
 package io.kestra.plugin.azure.eventhubs;
 
-import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
 import io.kestra.plugin.azure.eventhubs.serdes.Serdes;
 import io.kestra.plugin.azure.eventhubs.service.consumer.StartingPosition;
 import io.swagger.v3.oas.annotations.media.Schema;
 
-import java.time.Duration;
 import java.util.Map;
 
 /**

src/main/java/io/kestra/plugin/azure/eventhubs/Produce.java

@@ -22,7 +22,7 @@
 import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
+
 
 import java.io.*;
 import java.util.HashMap;
@@ -86,7 +86,6 @@
 @Schema(
     title = "Publish events to Azure Event Hubs."
 )
-@Slf4j
 @SuperBuilder
 @Getter
 @NoArgsConstructor

src/main/java/io/kestra/plugin/azure/eventhubs/RealtimeTrigger.java

@@ -19,13 +19,11 @@
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
 import org.reactivestreams.Publisher;
 import org.slf4j.Logger;
 import reactor.core.publisher.Flux;
 
 import java.time.Duration;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.CountDownLatch;
@@ -102,7 +100,6 @@
     title = "Trigger a flow on message consumption in real-time from Azure Event Hubs.",
     description = "If you would like to consume multiple messages processed within a given time frame and process them in batch, you can use the [io.kestra.plugin.azure.eventhubs.Trigger](https://kestra.io/plugins/plugin-azure/triggers/io.kestra.plugin.azure.eventhubs.trigger) instead."
 )
-@Slf4j
 @NoArgsConstructor
 @SuperBuilder
 @ToString

src/main/java/io/kestra/plugin/azure/eventhubs/Trigger.java

@@ -13,10 +13,9 @@
 import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
+
 
 import java.time.Duration;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;
@@ -56,7 +55,7 @@
     title = "Trigger a flow on message consumption periodically from Azure Event Hubs.",
     description = "If you would like to consume each message from Azure Event Hubs in real-time and create one execution per message, you can use the [io.kestra.plugin.azure.eventhubs.RealtimeTrigger](https://kestra.io/plugins/plugin-azure/triggers/io.kestra.plugin.azure.eventhubs.realtimetrigger) instead."
 )
-@Slf4j
+
 @NoArgsConstructor
 @SuperBuilder
 @ToString

src/main/java/io/kestra/plugin/azure/eventhubs/client/EventHubClientFactory.java

@@ -15,14 +15,17 @@
 import io.kestra.plugin.azure.eventhubs.config.BlobContainerClientConfig;
 import io.kestra.plugin.azure.eventhubs.config.EventHubClientConfig;
 import io.kestra.plugin.azure.eventhubs.config.EventHubConsumerConfig;
-import lombok.extern.slf4j.Slf4j;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.time.Duration;
 import java.util.Objects;
 import java.util.Optional;
 
-@Slf4j
 public class EventHubClientFactory {
+    private static final Logger log = LoggerFactory.getLogger(EventHubClientFactory.class);
+
 
     /**
      * Factory method for constructing a new {@link EventHubClientBuilder} for the given config.

src/main/java/io/kestra/plugin/azure/eventhubs/service/consumer/ConsumerContext.java

@@ -1,7 +1,8 @@
 package io.kestra.plugin.azure.eventhubs.service.consumer;
+import org.slf4j.Logger;
 
 import io.kestra.plugin.azure.eventhubs.service.EventDataObjectConverter;
-import org.slf4j.Logger;
+
 
 import java.time.Duration;
 

src/main/java/io/kestra/plugin/azure/eventhubs/service/consumer/EventHubConsumerService.java

@@ -1,4 +1,5 @@
 package io.kestra.plugin.azure.eventhubs.service.consumer;
+import org.slf4j.Logger;
 
 import com.azure.messaging.eventhubs.CheckpointStore;
 import com.azure.messaging.eventhubs.EventData;
@@ -12,8 +13,7 @@
 import io.kestra.plugin.azure.eventhubs.client.EventHubClientFactory;
 import io.kestra.plugin.azure.eventhubs.config.EventHubConsumerConfig;
 import io.kestra.plugin.azure.eventhubs.model.EventDataObject;
-import lombok.extern.slf4j.Slf4j;
-import org.slf4j.Logger;
+
 
 import java.util.Collection;
 import java.util.Collections;
@@ -31,7 +31,6 @@
 
 import static io.kestra.core.utils.Rethrow.throwFunction;
 
-@Slf4j
 public final class EventHubConsumerService {
 
     private final EventHubClientFactory clientFactory;

src/main/java/io/kestra/plugin/azure/eventhubs/service/producer/EventHubProducerService.java

@@ -1,4 +1,5 @@
 package io.kestra.plugin.azure.eventhubs.service.producer;
+import org.slf4j.Logger;
 
 import com.azure.messaging.eventhubs.EventData;
 import com.azure.messaging.eventhubs.EventDataBatch;
@@ -10,7 +11,7 @@
 import io.kestra.plugin.azure.eventhubs.config.EventHubConsumerConfig;
 import io.kestra.plugin.azure.eventhubs.model.EventDataObject;
 import io.kestra.plugin.azure.eventhubs.service.EventDataObjectConverter;
-import org.slf4j.Logger;
+
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 

src/main/java/io/kestra/plugin/azure/eventhubs/service/producer/ProducerContext.java

@@ -14,6 +14,6 @@
 public record ProducerContext(String bodyContentType,
                               Map<String, String> eventProperties,
                               Integer maxEventsPerBatch,
-                              Logger logger
+                              Logger     logger
 ) {
 }

src/main/java/io/kestra/plugin/azure/storage/adls/Delete.java

@@ -1,4 +1,5 @@
 package io.kestra.plugin.azure.storage.adls;
+import org.slf4j.Logger;
 
 import com.azure.storage.file.datalake.DataLakeFileClient;
 import io.kestra.core.models.annotations.Example;

src/main/java/io/kestra/plugin/azure/storage/adls/DeleteFiles.java

@@ -1,4 +1,5 @@
 package io.kestra.plugin.azure.storage.adls;
+import org.slf4j.Logger;
 
 import com.azure.storage.file.datalake.DataLakeFileClient;
 import com.azure.storage.file.datalake.DataLakeFileSystemClient;
@@ -21,7 +22,7 @@
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import org.apache.commons.lang3.tuple.Pair;
-import org.slf4j.Logger;
+
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.FluxSink;
 import reactor.core.scheduler.Schedulers;

src/main/java/io/kestra/plugin/azure/storage/blob/DeleteList.java

@@ -20,12 +20,13 @@
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import org.apache.commons.lang3.tuple.Pair;
-import org.slf4j.Logger;
+
 
 import java.util.NoSuchElementException;
 import java.util.function.Function;
 
 import jakarta.validation.constraints.Min;
+import org.slf4j.Logger;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.FluxSink;
 import reactor.core.scheduler.Schedulers;