From 8304a16aece5d1811f94ae94119edadc88eb5fe4 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Wed, 22 Jan 2025 15:47:51 +0100
Subject: [PATCH] Call close on KafkaApplication only once

Fixes #263
---
 .../src/main/java/com/bakdata/kafka/KafkaApplication.java     | 4 +---
 1 file changed, 1 insertion(+), 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
index 9f91614b..15b68e12 100644
--- 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