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 @@ [], + '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' => [], + ], + ], ]; 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; } /**