Call close on KafkaApplication only once

Fixes #263
bakdata · Jan 22, 2025 · 8304a16 · 8304a16
1 parent fc58852
commit 8304a16
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaApplication.java
@@ -296,9 +296,7 @@ private void startApplication() {
 
     private int execute(final ParseResult parseResult) {
         this.startApplication();
-        final int exitCode = new CommandLine.RunLast().execute(parseResult);
-        this.close();
-        return exitCode;
+        return new CommandLine.RunLast().execute(parseResult);
     }
 
     @FunctionalInterface