Create v3

bakdata · Apr 9, 2024 · cdd5036 · cdd5036
1 parent 8cbf276
commit cdd5036
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CloseFlagApp.java b/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CloseFlagApp.java
@@ -54,7 +54,7 @@ public void buildTopology(final TopologyBuilder builder) {
 
             @Override
             public String getUniqueAppId(final StreamsTopicConfig topics) {
-                return this.getClass().getSimpleName() + "-" + topics.getOutputTopic();
+                return CloseFlagApp.this.getClass().getSimpleName() + "-" + topics.getOutputTopic();
             }
 
             @Override