Merge branch 'main' into vertical-scaling

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

@@ -60,7 +60,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

@@ -60,7 +60,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

@@ -60,7 +60,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

@@ -61,7 +61,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/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);
     }
 
   }