diff --git a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java index e640dc9c85d4b6a9f3b40e77eb7ae4dd14ad9c19..9025ae35a15e17ae7501547777bfd63d2dbcb5a3 100644 --- a/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java @@ -34,8 +34,7 @@ public class HistoryService extends HazelcastJetService { StringSerializer.class.getCanonicalName(), StringSerializer.class.getCanonicalName()); - final String kafkaOutputTopic = - this.config.getProperty(Uc2ConfigurationKeys.KAFKA_OUTPUT_TOPIC).toString(); + final String kafkaOutputTopic = this.config.getString(Uc2ConfigurationKeys.KAFKA_OUTPUT_TOPIC); final Duration downsampleInterval = Duration.ofMinutes( this.config.getInt(Uc2ConfigurationKeys.DOWNSAMPLE_INTERVAL_MINUTES));