Update

bakdata · Apr 15, 2024 · b5dd8ce · b5dd8ce
1 parent ebe1ec0
commit b5dd8ce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...afka-streams-tests/src/main/java/com/bakdata/fluent_kafka_streams_tests/TestTopology.java b/...afka-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;