Merge pull request #23 from ensi-platform/ecs-2131

ECS-2131

Author: MsNatali

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"

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' => [],
+        ],
+    ],
 ];

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;
     }
 
     /**