KafkaStreamsProducer no longer shuts down the injected executorservice

Fixes quarkusio#43228
ozangunalp · Sep 13, 2024 · 75e7d58 · 75e7d58
1 parent b8c5a62
commit 75e7d58
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/...-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java b/...-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();