Merge pull request #43263 from ozangunalp/kafka_streams_shutdown_fix

KafkaStreamsProducer no longer shuts down the injected executorservice
quarkusio · Sep 13, 2024 · c146936 · c146936
2 parents e20deb4 + 75e7d58
commit c146936
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();