From 75e7d58fb6cc011049c615bd1c20a66f1ff18e8f Mon Sep 17 00:00:00 2001
From: Ozan Gunalp <ozangunalp@gmail.com>
Date: Fri, 13 Sep 2024 09:40:55 +0200
Subject: [PATCH] KafkaStreamsProducer no longer shuts down the injected
 executorservice

Fixes #43228
---
 .../io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
index 570ab735c8f07..078fa15e338f7 100644
--- a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
+++ b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
@@ -164,9 +164,6 @@ public KafkaStreamsTopologyManager kafkaStreamsTopologyManager() {
 
     void onStop(@Observes ShutdownEvent event) {
         shutdown = true;
-        if (executorService != null) {
-            executorService.shutdown();
-        }
         if (kafkaStreams != null) {
             LOGGER.debug("Stopping Kafka Streams pipeline");
             kafkaStreams.close();