Merge pull request #5 from Sin30/config-adjustment

Adjust default value for config auto.offset.reset #5 by Sin30

Author: petermein

src/Queue/Connectors/KafkaConnector.php

@@ -6,7 +6,7 @@
 use Illuminate\Queue\Connectors\ConnectorInterface;
 use Rapide\LaravelQueueKafka\Queue\KafkaQueue;
 use RdKafka\Conf;
-use RdKafka\Consumer;
+use RdKafka\KafkaConsumer;
 use RdKafka\Producer;
 use RdKafka\TopicConf;
 
@@ -42,7 +42,7 @@ public function connect(array $config)
 
         /** @var TopicConf $topicConf */
         $topicConf = $this->container->makeWith('queue.kafka.topic_conf', []);
-        $topicConf->set('auto.offset.reset', 'smallest');
+        $topicConf->set('auto.offset.reset', 'largest');
 
         /** @var Conf $conf */
         $conf = $this->container->makeWith('queue.kafka.conf', []);
@@ -52,7 +52,7 @@ public function connect(array $config)
         $conf->set('offset.store.method', 'broker');
         $conf->setDefaultTopicConf($topicConf);
 
-        /** @var Consumer $consumer */
+        /** @var KafkaConsumer $consumer */
         $consumer = $this->container->makeWith('queue.kafka.consumer', ['conf' => $conf]);
 
         return new KafkaQueue(