Commit 66de991f authored by Evgenii Burikov's avatar Evgenii Burikov
Browse files

use default group in consumer fix

parent ef6f7453
No related merge requests found
Showing with 2 additions and 1 deletion
+2 -1
......@@ -12,7 +12,7 @@ class KafkaQueue extends Command
*
* @var string
*/
protected $signature = 'kafka:queue {group_name = null} {--offset_reset = earliest}';
protected $signature = 'kafka:queue {group_name?} {--offset_reset = earliest}';
/**
* The console command description.
......
......@@ -56,6 +56,7 @@ class KafkaService
}
public function consume (String $group = null, String $offsetReset = 'earliest') {
// if (!$group) $group=
$consumer = Kafka::createConsumer($this->getTopicsToConsume(), $group)
->withOptions($this->configOptions)
->withOptions([
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment