diff --git a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java index 0605854..2af58f2 100644 --- a/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java +++ b/fluent-kafka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java @@ -292,7 +292,7 @@ public void start() { } this.properties.put(StreamsConfig.STATE_DIR_CONFIG, this.stateDirectory.toAbsolutePath().toString()); final Topology topology = this.topologyFactory.apply(this.properties); - this.testDriver = new TopologyTestDriver(topology, this.getProperties()); + this.testDriver = new TopologyTestDriver(topology, this.createProperties()); this.inputTopics.clear(); this.inputPatterns.clear(); @@ -451,7 +451,7 @@ public void stop() { } } - private Properties getProperties() { + private Properties createProperties() { final Properties props = new Properties(); props.putAll(this.properties); return props;