Merge pull request #3308 from apache/Kafka-Shutdown

[ISSUE #3307] Kafka Consumer Shuts Down Properly
apache · Mar 2, 2023 · 984537d · 984537d
2 parents 6636e3a + 7d37d23
commit 984537d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...ector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java b/...ector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
@@ -82,7 +82,9 @@ public void start() {
 
     public synchronized void shutdown() {
         if (this.started.compareAndSet(true, false)) {
-            this.kafkaConsumer.close();
+            // Shutdown the executor and interrupt any running tasks
+            kafkaConsumerRunner.shutdown();
+            executorService.shutdown();
         }
     }