init

Author: soulaimaneyahyax

composer.json

@@ -17,7 +17,7 @@
         "php": "^8.2",
         "laravel/lumen-framework": "^10.0",
         "squizlabs/php_codesniffer": "^3.7",
-        "jobcloud/php-kafka-lib": "^2.0"
+        "jobcloud/php-kafka-lib": "^1.0"
     },
     "scripts": {
         "php-fixer": [

composer.lock

@@ -3,6 +3,7 @@
 declare(strict_types=1);
 
 namespace Kafka\Services;
+
 use Kafka\Jobs\Job;
 use Illuminate\Queue\Queue;
 use Jobcloud\Kafka\Producer\KafkaProducer;
@@ -33,7 +34,8 @@ public function __construct($producer, $consumer)
      */
     public function push($job, $data = '', $queue = null)
     {
-        $message = KafkaProducerMessage::create(config('queue.connections.kafka.topic-name'), 0)->withBody(serialize($job));
+        $message = KafkaProducerMessage::create(config('queue.connections.kafka.topic-name'), 0)
+            ->withBody(serialize($job));
 
         $this->producer->produce($message);