Merge branch 'main' into add-uc4-kstreams-topology-test

docs/project-info.md

@@ -26,6 +26,7 @@ Theodolite's internal development including issue boards, merge requests and ext
 * [Lorenz Boguhn](https://github.com/lorenzboguhn)
 * [Simon Ehrenstein](https://github.com/sehrenstein)
 * [Willi Hasselbring](https://www.se.informatik.uni-kiel.de/en/team/prof.-dr.-wilhelm-willi-hasselbring)
+* [Luca Mertens](https://www.linkedin.com/in/luca-mertens-35a932201)
 * [Tobias Pfandzelter](https://pfandzelter.com/)
 * [Julia Rossow](https://www.linkedin.com/in/julia-rossow/)
 * [Björn Vonheiden](https://github.com/bvonheid)

theodolite-benchmarks/definitions/uc1-hazelcastjet/uc1-hazelcastjet-benchmark-operator.yaml

@@ -44,7 +44,7 @@ spec:
       prometheusUrl: "http://prometheus-operated:9090"
       offset: 0
       properties:
-        consumerGroup: uc1-hazelcastjet
+        consumerGroup: theodolite-uc1-application
         threshold: 2000
         externalSloUrl: "http://localhost:80/evaluate-slope"
         warmup: 60 # in seconds

theodolite-benchmarks/definitions/uc2-hazelcastjet/uc2-hazelcastjet-benchmark-operator.yaml

@@ -44,7 +44,7 @@ spec:
       prometheusUrl: "http://prometheus-operated:9090"
       offset: 0
       properties:
-        consumerGroup: uc2-hazelcastjet
+        consumerGroup: theodolite-uc2-application
         threshold: 2000
         externalSloUrl: "http://localhost:80/evaluate-slope"
         warmup: 60 # in seconds

theodolite-benchmarks/definitions/uc3-hazelcastjet/uc3-hazelcastjet-benchmark-operator.yaml

@@ -44,7 +44,7 @@ spec:
       prometheusUrl: "http://prometheus-operated:9090"
       offset: 0
       properties:
-        consumerGroup: uc3-hazelcastjet
+        consumerGroup: theodolite-uc3-application
         threshold: 2000
         externalSloUrl: "http://localhost:80/evaluate-slope"
         warmup: 60 # in seconds

theodolite-benchmarks/definitions/uc4-hazelcastjet/uc4-hazelcastjet-benchmark-operator.yaml

@@ -45,7 +45,7 @@ spec:
       prometheusUrl: "http://prometheus-operated:9090"
       offset: 0
       properties:
-        consumerGroup: uc4-hazelcastjet
+        consumerGroup: theodolite-uc4-application
         threshold: 2000
         externalSloUrl: "http://localhost:80/evaluate-slope"
         warmup: 60 # in seconds

theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml

@@ -51,6 +51,7 @@ services:
       SAMZA_SYSTEMS_KAFKA_CONSUMER_BOOTSTRAP_SERVERS: kafka:9092
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
+      ENABLE_METRICS: "false"
   load-generator: 
     image: ghcr.io/cau-se/theodolite-uc1-workload-generator:${THEODOLITE_TAG:-latest}
     depends_on:

theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml

@@ -51,6 +51,7 @@ services:
       SAMZA_SYSTEMS_KAFKA_CONSUMER_BOOTSTRAP_SERVERS: kafka:9092
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
+      ENABLE_METRICS: "false"
   load-generator: 
     image: ghcr.io/cau-se/theodolite-uc2-workload-generator:${THEODOLITE_TAG:-latest}
     depends_on:

theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml

@@ -51,6 +51,7 @@ services:
       SAMZA_SYSTEMS_KAFKA_CONSUMER_BOOTSTRAP_SERVERS: kafka:9092
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
+      ENABLE_METRICS: "false"
   load-generator: 
     image: ghcr.io/cau-se/theodolite-uc3-workload-generator:${THEODOLITE_TAG:-latest}
     depends_on:

theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml

@@ -51,6 +51,7 @@ services:
       SAMZA_SYSTEMS_KAFKA_CONSUMER_BOOTSTRAP_SERVERS: kafka:9092
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
+      ENABLE_METRICS: "false"
   load-generator: 
     image: ghcr.io/cau-se/theodolite-uc4-workload-generator:${THEODOLITE_TAG:-latest}
     depends_on:

theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/KafkaConnectorFactory.java

@@ -21,7 +21,7 @@ import rocks.theodolite.benchmarks.commons.flink.util.SerializableSupplier;
 /**
  * A class for creating {@link FlinkKafkaConsumer} and {@link FlinkKafkaProducer}.
  */
-public class KafkaConnectorFactory {
+public class KafkaConnectorFactory { // NOPMD
 
   private static final String AUTO_OFFSET_RESET_EARLIEST = "earliest";
 

theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/JetInstanceBuilder.java

@@ -3,6 +3,7 @@ package rocks.theodolite.benchmarks.commons.hazelcastjet;
 import com.hazelcast.config.Config;
 import com.hazelcast.jet.Jet;
 import com.hazelcast.jet.JetInstance;
+import com.hazelcast.jet.config.JetConfig;
 import org.slf4j.Logger;
 
 /**
@@ -48,13 +49,13 @@ public class JetInstanceBuilder {
    * @return JetInstance
    */
   public JetInstance build() {
-    final JetInstance jet = Jet.newJetInstance();
     final Config localConfig = this.config;
     if (localConfig == null) {
-      return jet;
+      throw new IllegalStateException("No Hazelcast config set.");
     } else {
-      jet.getConfig().setHazelcastConfig(localConfig);
-      return jet;
+      final JetConfig jetConfig = new JetConfig();
+      jetConfig.setHazelcastConfig(localConfig);
+      return Jet.newJetInstance(jetConfig);
     }
 
   }