Adds fresh

src/Contracts/Manager.php

@@ -4,6 +4,9 @@
 
 interface Manager
 {
+    /** Returns a new fresh instance of the Manager. */
+    public function fresh(): self;
+
     /** Creates a new ProducerBuilder instance, setting brokers and topic. */
     public function publish(?string $broker = null): MessageProducer;
 

src/Facades/Kafka.php

@@ -9,6 +9,7 @@
 /**
  * @method static \Junges\Kafka\Contracts\MessageProducer publish(string $broker = null)
  * @method static \Junges\Kafka\Contracts\MessageProducer asyncPublish(string $broker = null)
+ * @method static \Junges\Kafka\Factory fresh(string $broker = null)
  * @method static \Junges\Kafka\Consumers\Builder consumer(array $topics = [], string $groupId = null, string $brokers = null)
  * @method static void assertPublished(ProducerMessage $expectedMessage = null, callable $callback = null)
  * @method static void assertPublishedTimes(int $times = 1, ProducerMessage $expectedMessage = null, callable $callback = null)

src/Factory.php

@@ -33,6 +33,12 @@ public function publish(string $broker = null): MessageProducer
         );
     }
 
+    /** Returns a fresh factory instance. */
+    public function fresh(): self
+    {
+        return new self;
+    }
+
     /**
      * Creates a new ProducerBuilder instance, optionally setting the brokers.
      * The producer will be flushed only when the application terminates,