Add initial logging statements to load generators

uc1-workload-generator/src/main/java/uc1/workloadGenerator/LoadGenerator.java

@@ -19,12 +19,13 @@ import titan.ccp.models.records.ActivePowerRecord;
 
 public class LoadGenerator {
 
-  private static Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
 
   private static final int WL_MAX_RECORDS = 150_000;
 
   public static void main(final String[] args) throws InterruptedException, IOException {
     // uc1
+    LOGGER.info("Start workload generator for use case UC1.");
 
     final int numSensors =
         Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));

uc2-workload-generator/src/main/java/uc2/workloadGenerator/LoadGenerator.java

@@ -11,6 +11,8 @@ import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import kafkaSender.KafkaRecordSender;
 import org.apache.kafka.clients.producer.ProducerConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import titan.ccp.configuration.events.Event;
 import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
 import titan.ccp.model.sensorregistry.MutableSensorRegistry;
@@ -18,7 +20,10 @@ import titan.ccp.models.records.ActivePowerRecord;
 
 public class LoadGenerator {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
   public static void main(final String[] args) throws InterruptedException, IOException {
+    LOGGER.info("Start workload generator for use case UC2.");
 
     final String hierarchy = Objects.requireNonNullElse(System.getenv("HIERARCHY"), "deep");
     final int numNestedGroups = Integer

uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java

@@ -11,14 +11,19 @@ import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import kafkaSender.KafkaRecordSender;
 import org.apache.kafka.clients.producer.ProducerConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
 import titan.ccp.model.sensorregistry.MutableSensorRegistry;
 import titan.ccp.models.records.ActivePowerRecord;
 
 public class LoadGenerator {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
   public static void main(final String[] args) throws InterruptedException, IOException {
     // uc3
+    LOGGER.info("Start workload generator for use case UC3.");
 
     final int numSensor =
         Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));

uc4-workload-generator/src/main/java/uc4/workloadGenerator/LoadGenerator.java

@@ -12,12 +12,17 @@ import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import kafkaSender.KafkaRecordSender;
 import org.apache.kafka.clients.producer.ProducerConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import titan.ccp.models.records.ActivePowerRecord;
 
 public class LoadGenerator {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(LoadGenerator.class);
+
   public static void main(final String[] args) throws InterruptedException, IOException {
     // uc4
+    LOGGER.info("Start workload generator for use case UC4.");
 
     final int numSensor =
         Integer.parseInt(Objects.requireNonNullElse(System.getenv("NUM_SENSORS"), "10"));