Removes unused imports and unused properties

arquivei · Dec 1, 2021 · 4e4bf21 · 4e4bf21
1 parent 8a60f39
commit 4e4bf21
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 9 deletions.
diff --git a/src/Commit/RetryableCommitter.php b/src/Commit/RetryableCommitter.php
@@ -5,7 +5,6 @@
 namespace Kafka\Consumer\Commit;
 
 use Kafka\Consumer\Retry\Retryable;
-use RdKafka\Exception;
 
 /**
  * Decorates a committer with retry logic

diff --git a/src/Laravel/Console/Commands/PhpKafkaConsumerCommand.php b/src/Laravel/Console/Commands/PhpKafkaConsumerCommand.php
@@ -3,9 +3,6 @@
 namespace Kafka\Consumer\Laravel\Console\Commands;
 
 use Illuminate\Console\Command;
-use Kafka\Consumer\Contracts\Consumer;
-use Kafka\Consumer\Exceptions\InvalidCommitException;
-use Kafka\Consumer\Exceptions\InvalidConsumerException;
 use Kafka\Consumer\Laravel\Console\Commands\PhpKafkaConsumer\Options;
 use Kafka\Consumer\Validators\Commands\PhpKafkaConsumer\Validator;
 
@@ -14,11 +11,7 @@ class PhpKafkaConsumerCommand extends Command
     protected $signature = 'arquivei:php-kafka-consumer {--topic=*} {--consumer=} {--groupId=} {--commit=} {--dlq=} {--maxMessage=}';
     protected $description = 'An Apache Kafka consumer in PHP';
 
-    private $dlq;
-    private $topics;
     private $config;
-    private $groupId;
-    private $maxMessage;
 
     public function __construct()
     {
@@ -31,7 +24,7 @@ public function handle()
         (new Validator())->validateOptions($this->options());
         $options = $this->options();
         $options['groupId'] = $options['groupId'] ?? $this->config['groupId'];
-        $options = new Options($this->options());
+        $options = new Options($options);
 
         $consumer = $options->getConsumer();
         $config = new \Kafka\Consumer\Entities\Config(