Minor refactorings

theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java

@@ -72,11 +72,11 @@ public class PipelineFactory extends AbstractPipelineFactory {
     final String configurationTopic =
         this.config.getString(ConfigurationKeys.KAFKA_CONFIGURATION_TOPIC);
 
-    final Duration duration = Duration.standardSeconds(
-        this.config.getInt(ConfigurationKeys.EMIT_PERIOD_SECONDS));
+    final Duration duration = Duration.millis(
+        this.config.getInt(ConfigurationKeys.EMIT_PERIOD_MS));
     final Duration triggerDelay = Duration.standardSeconds(
         this.config.getInt(ConfigurationKeys.TRIGGER_INTERVAL_SECONDS));
-    final Duration gracePeriod = Duration.standardSeconds(
+    final Duration gracePeriod = Duration.standardSeconds( // TODO this is wrong
         this.config.getInt(ConfigurationKeys.GRACE_PERIOD_MS));
 
     // Read from Kafka

theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties

@@ -9,7 +9,7 @@ kafka.feedback.topic=aggregation-feedback
 
 schema.registry.url=http://localhost:8081
 
-kafka.window.duration.minutes=1
+emit.period.ms=5000
 trigger.interval=15
 grace.period.ms=270