Removed variables

Author: petermein

config/kafka.php

@@ -6,7 +6,6 @@
  * You need to set proper values in `.env`.
  */
 return [
-
     /*
      * Driver name
      */

src/Queue/Jobs/KafkaJob.php

@@ -3,7 +3,6 @@
 namespace Rapide\LaravelQueueKafka\Queue\Jobs;
 
 use Exception;
-use Illuminate\Container\Container;
 use Illuminate\Contracts\Queue\Job as JobContract;
 use Illuminate\Database\DetectsDeadlocks;
 use Illuminate\Queue\Jobs\Job;
@@ -16,13 +15,7 @@ class KafkaJob extends Job implements JobContract
 {
     use DetectsDeadlocks;
 
-    /**
-     * Same as RabbitMQQueue, used for attempt counts.
-     */
-    const ATTEMPT_COUNT_HEADERS_KEY = 'attempts_count';
-
     protected $connection;
-    protected $channel;
     protected $queue;
     protected $message;
 
@@ -37,7 +30,8 @@ public function __construct(
         KafkaQueue $connection,
         Message $message,
         $queue
-    ) {
+    )
+    {
         $this->connection = $connection;
         $this->queue = $queue;
         $this->message = $message;

src/Queue/KafkaQueue.php

@@ -170,8 +170,6 @@ private function getTopic($queue)
      * Sets the correlation id for a message to be published.
      *
      * @param string $id
-     *
-     * @return void
      */
     public function setCorrelationId($id)
     {