diff --git a/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/TopologyBuilder.java b/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/TopologyBuilder.java index 3dba062b31549712f4df2dc84f3a4f71572999d8..74e9bb99b80efec4c27d7eb50668d622a5d951f9 100644 --- a/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/TopologyBuilder.java +++ b/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/TopologyBuilder.java @@ -60,9 +60,9 @@ public class TopologyBuilder { final Duration emitPeriod, final Duration gracePeriod, final SchemaRegistryAvroSerdeFactory srAvroSerdeFactory) { this.inputTopic = inputTopic; + this.outputTopic = outputTopic; this.feedbackTopic = feedbackTopic; this.configurationTopic = configurationTopic; - this.outputTopic = outputTopic; this.emitPeriod = emitPeriod; this.gracePeriod = gracePeriod; diff --git a/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java b/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java index 78f73268e0ed7a30d5fe6105bab7d4b05897527f..7e077b101c0e1bfab359fc347ffe8c4acc9b88fc 100644 --- a/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java +++ b/benchmarks/uc2-application/src/main/java/theodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java @@ -60,8 +60,8 @@ public class Uc2KafkaStreamsBuilder extends KafkaStreamsBuilder { // NOPMD build final TopologyBuilder topologyBuilder = new TopologyBuilder( this.inputTopic, - this.feedbackTopic, this.outputTopic, + this.feedbackTopic, this.configurationTopic, this.emitPeriod == null ? EMIT_PERIOD_DEFAULT : this.emitPeriod, this.gracePeriod == null ? GRACE_PERIOD_DEFAULT : this.gracePeriod,