diff --git a/src/Commit/RetryableCommitter.php b/src/Commit/RetryableCommitter.php index f23502d..9ca5e5e 100644 --- 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 index efd1295..52fc884 100644 --- 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(