diff --git a/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/Uc4PipelineFactory.java b/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/Uc4PipelineFactory.java index e0ba823596474f87c79d488a5bbe7e71749f54fb..59b5941fb9f0090074869b00d49ad26c68e40165 100644 --- a/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/Uc4PipelineFactory.java +++ b/theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/Uc4PipelineFactory.java @@ -109,7 +109,7 @@ public class Uc4PipelineFactory extends PipelineFactory { this.kafkaWritePropsForPipeline, this.kafkaFeedbackTopic)); // Log aggregation product - uc4Aggregation.writeTo(Sinks.logger()); + // uc4Aggregation.writeTo(Sinks.logger()); // Add Sink2: Write back to kafka output topic uc4Aggregation.writeTo(KafkaSinks.kafka(