KafkaStreamsProducer no longer shuts down the injected executorservice

Fixes quarkusio#43228 (cherry picked from commit 75e7d58)
gsmet · Sep 13, 2024 · b8062cc · b8062cc
1 parent 7133446
commit b8062cc
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();