From f16dd1031ed29b0f9ff9111e5ce3129ff6e3b5bd Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Thu, 23 Jan 2025 15:44:14 +0100 Subject: [PATCH] Update --- .../bakdata/kafka/TestApplicationRunner.java | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) diff --git a/streams-bootstrap-cli-test/src/main/java/com/bakdata/kafka/TestApplicationRunner.java b/streams-bootstrap-cli-test/src/main/java/com/bakdata/kafka/TestApplicationRunner.java index 72509d4d..cd041def 100644 --- a/streams-bootstrap-cli-test/src/main/java/com/bakdata/kafka/TestApplicationRunner.java +++ b/streams-bootstrap-cli-test/src/main/java/com/bakdata/kafka/TestApplicationRunner.java @@ -42,17 +42,10 @@ public final class TestApplicationRunner { private final @NonNull String bootstrapServers; private final @NonNull SchemaRegistryEnv schemaRegistryEnv; - private static Thread start(final Runnable runnable) { - final Thread thread = new Thread(runnable); - final UncaughtExceptionHandler handler = new CapturingUncaughtExceptionHandler(); - thread.setUncaughtExceptionHandler(handler); - thread.start(); - return thread; - } - - public Thread run(final KafkaStreamsApplication app, final String[] args) { + public void run(final KafkaStreamsApplication app, final String[] args) { final String[] newArgs = this.setupArgs(args, emptyList()); - return start(() -> KafkaApplication.startApplicationWithoutExit(app, newArgs)); + final Thread thread = new Thread(() -> KafkaApplication.startApplicationWithoutExit(app, newArgs)); + thread.start(); } public int clean(final KafkaStreamsApplication app, final String[] args) { @@ -67,7 +60,11 @@ public int reset(final KafkaStreamsApplication app, final public Thread run(final KafkaStreamsApplication app) { this.prepareExecution(app); - return start(app); + final Thread thread = new Thread(app); + final UncaughtExceptionHandler handler = new CapturingUncaughtExceptionHandler(); + thread.setUncaughtExceptionHandler(handler); + thread.start(); + return thread; } public void clean(final KafkaStreamsApplication app) {