From f41b2ba8fd679ead87f69474e6912d54bb3f9f16 Mon Sep 17 00:00:00 2001
From: Ms_Natali <golubkova@greensight.ru>
Date: Thu, 25 Sep 2025 16:58:50 +0300
Subject: [PATCH 1/2] ECS-2131

---
 src/Commands/KafkaConsumeCommand.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Commands/KafkaConsumeCommand.php b/src/Commands/KafkaConsumeCommand.php
index 10a6b53..1e27156 100644
--- a/src/Commands/KafkaConsumeCommand.php
+++ b/src/Commands/KafkaConsumeCommand.php
@@ -74,7 +74,7 @@ public function handleSignal(int $signal, int|false $previousExitCode = 0): int|
             $this->consumer->forceStop();
         }
 
-        return $previousExitCode;
+        return false;
     }
 
     /**

From aaba68e662d0a686eca81eae9b581e3da92239ee Mon Sep 17 00:00:00 2001
From: Ms_Natali <golubkova@greensight.ru>
Date: Thu, 25 Sep 2025 17:05:12 +0300
Subject: [PATCH 2/2] ECS-2131

---
 composer.json             |  1 +
 config/kafka-consumer.php | 37 +++++++++++++++++++------------------
 2 files changed, 20 insertions(+), 18 deletions(-)

diff --git a/composer.json b/composer.json
index bf6b6c0..2bc2e1f 100644
--- a/composer.json
+++ b/composer.json
@@ -5,6 +5,7 @@
     "license": "MIT",
     "require": {
         "php": "^8.1",
+        "ext-pcntl": "*",
         "ext-rdkafka": "*",
         "ensi/laravel-phprdkafka": "^0.4.0",
         "laravel/framework": "^10.0 || ^11.0"
diff --git a/config/kafka-consumer.php b/config/kafka-consumer.php
index 73259c1..9b27790 100644
--- a/config/kafka-consumer.php
+++ b/config/kafka-consumer.php
@@ -1,26 +1,27 @@
 <?php
 
 return [
-   'global_middleware' => [],
+    'global_middleware' => [],
+    'stop_signals' => [SIGTERM, SIGINT, SIGQUIT],
 
-   'processors' => [],
+    'processors' => [],
 
-   'log_channel' => env('KAFKA_CONSUMER_LOG_CHANNEL', 'null'),
+    'log_channel' => env('KAFKA_CONSUMER_LOG_CHANNEL', 'null'),
 
-   'consumer_options' => [
-      /** options for consumer with name `default` */
-      'default' => [
-         /*
-         | Optional, defaults to 20000.
-         | Kafka consume timeout in milliseconds.
-         */
-        'consume_timeout' => 20000,
+    'consumer_options' => [
+        /** options for consumer with name `default` */
+        'default' => [
+            /*
+            | Optional, defaults to 20000.
+            | Kafka consume timeout in milliseconds.
+            */
+            'consume_timeout' => 20000,
 
-         /*
-         | Optional, defaults to empty array.
-         | Array of middleware.
-         */
-        'middleware' => [],
-      ],
-   ],
+            /*
+            | Optional, defaults to empty array.
+            | Array of middleware.
+            */
+            'middleware' => [],
+        ],
+    ],
 ];