Fix typos

theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/HistoryService.java

@@ -34,7 +34,7 @@ public class HistoryService {
     final Uc3KafkaStreamsBuilder uc3KafkaStreamsBuilder = new Uc3KafkaStreamsBuilder(this.config);
     uc3KafkaStreamsBuilder
         .outputTopic(this.config.getString(ConfigurationKeys.KAFKA_OUTPUT_TOPIC))
-        .aggregtionDuration(
+        .aggregationDuration(
             Duration.ofDays(this.config.getInt(ConfigurationKeys.AGGREGATION_DURATION_DAYS)))
         .aggregationAdvance(
             Duration.ofDays(this.config.getInt(ConfigurationKeys.AGGREGATION_ADVANCE_DAYS)));

theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/TopologyBuilder.java

@@ -34,7 +34,7 @@ public class TopologyBuilder {
   private final String inputTopic;
   private final String outputTopic;
   private final SchemaRegistryAvroSerdeFactory srAvroSerdeFactory;
-  private final Duration aggregtionDuration;
+  private final Duration aggregationDuration;
   private final Duration aggregationAdvance;
 
   private final StreamsBuilder builder = new StreamsBuilder();
@@ -44,11 +44,11 @@ public class TopologyBuilder {
    */
   public TopologyBuilder(final String inputTopic, final String outputTopic,
       final SchemaRegistryAvroSerdeFactory srAvroSerdeFactory,
-      final Duration aggregtionDuration, final Duration aggregationAdvance) {
+      final Duration aggregationDuration, final Duration aggregationAdvance) {
     this.inputTopic = inputTopic;
     this.outputTopic = outputTopic;
     this.srAvroSerdeFactory = srAvroSerdeFactory;
-    this.aggregtionDuration = aggregtionDuration;
+    this.aggregationDuration = aggregationDuration;
     this.aggregationAdvance = aggregationAdvance;
   }
 
@@ -70,7 +70,7 @@ public class TopologyBuilder {
         })
         .groupByKey(Grouped.with(keySerde, this.srAvroSerdeFactory.forValues()))
         .windowedBy(TimeWindows
-            .ofSizeWithNoGrace(this.aggregtionDuration)
+            .ofSizeWithNoGrace(this.aggregationDuration)
             .advanceBy(this.aggregationAdvance))
         .aggregate(
             () -> Stats.of(),

theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/Uc3KafkaStreamsBuilder.java

@@ -14,7 +14,7 @@ import rocks.theodolite.benchmarks.commons.kstreams.KafkaStreamsBuilder;
 public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
 
   private String outputTopic; // NOPMD
-  private Duration aggregtionDuration; // NOPMD
+  private Duration aggregationDuration; // NOPMD
   private Duration aggregationAdvance; // NOPMD
 
   public Uc3KafkaStreamsBuilder(final Configuration config) {
@@ -26,8 +26,8 @@ public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
     return this;
   }
 
-  public Uc3KafkaStreamsBuilder aggregtionDuration(final Duration aggregtionDuration) {
-    this.aggregtionDuration = aggregtionDuration;
+  public Uc3KafkaStreamsBuilder aggregationDuration(final Duration aggregationDuration) {
+    this.aggregationDuration = aggregationDuration;
     return this;
   }
 
@@ -40,14 +40,14 @@ public class Uc3KafkaStreamsBuilder extends KafkaStreamsBuilder {
   protected Topology buildTopology(final Properties properties) {
     Objects.requireNonNull(this.inputTopic, "Input topic has not been set.");
     Objects.requireNonNull(this.outputTopic, "Output topic has not been set.");
-    Objects.requireNonNull(this.aggregtionDuration, "Aggregation duration has not been set.");
+    Objects.requireNonNull(this.aggregationDuration, "Aggregation duration has not been set.");
     Objects.requireNonNull(this.aggregationAdvance, "Aggregation advance period has not been set.");
 
     final TopologyBuilder topologyBuilder = new TopologyBuilder(
         this.inputTopic,
         this.outputTopic,
         new SchemaRegistryAvroSerdeFactory(this.schemaRegistryUrl),
-        this.aggregtionDuration,
+        this.aggregationDuration,
         this.aggregationAdvance);
 
     return topologyBuilder.build(properties);