Fix deprecation warnings

Author: mateusjunges

src/Contracts/ConsumerBuilder.php

@@ -8,7 +8,7 @@
 interface ConsumerBuilder extends InteractsWithConfigCallbacks
 {
     /** Creates a new ConsumerBuilder instance. */
-    public static function create(string $brokers, array $topics = [], string $groupId = null): self;
+    public static function create(string $brokers, array $topics = [], ?string $groupId = null): self;
 
     /** Subscribe to a Kafka topic. */
     public function subscribe(...$topics): self;

src/Contracts/Logger.php

@@ -7,5 +7,5 @@
 
 interface Logger
 {
-    public function error(Message $message, Throwable $e = null, string $prefix = 'ERROR'): void;
+    public function error(Message $message, ?Throwable $e = null, string $prefix = 'ERROR'): void;
 }

src/Contracts/Manager.php

@@ -11,7 +11,7 @@ public function fresh(): self;
     public function publish(?string $broker = null): MessageProducer;
 
     /** Return a ConsumerBuilder instance. */
-    public function consumer(array $topics = [], string $groupId = null, string $brokers = null): ConsumerBuilder;
+    public function consumer(array $topics = [], ?string $groupId = null, ?string $brokers = null): ConsumerBuilder;
 
     public function shouldFake(): self;
 

src/Contracts/ProducerMessage.php

@@ -4,7 +4,7 @@
 
 interface ProducerMessage extends KafkaMessage
 {
-    public static function create(string $topicName = null, int $partition = RD_KAFKA_PARTITION_UA): ProducerMessage;
+    public static function create(?string $topicName = null, int $partition = RD_KAFKA_PARTITION_UA): ProducerMessage;
 
     public function withKey(mixed $key): ProducerMessage;
 

src/Factory.php

@@ -22,7 +22,7 @@ class Factory implements Manager
     private ?ProducerBuilder $builder = null;
 
     /** Creates a new ProducerBuilder instance, setting brokers and topic. */
-    public function publish(string $broker = null): MessageProducer
+    public function publish(?string $broker = null): MessageProducer
     {
         if ($this->shouldFake) {
             return Kafka::fake()->publish($broker);
@@ -44,7 +44,7 @@ public function fresh(): self
      * The producer will be flushed only when the application terminates,
      * and doing SEND does not mean that the message was flushed!
      */
-    public function asyncPublish(string $broker = null): MessageProducer
+    public function asyncPublish(?string $broker = null): MessageProducer
     {
         if ($this->shouldFake) {
             return Kafka::fake()->publish($broker);
@@ -63,13 +63,13 @@ public function asyncPublish(string $broker = null): MessageProducer
     }
 
     /** This is an alias for the asyncPublish method. */
-    public function publishAsync(string $broker = null): MessageProducer
+    public function publishAsync(?string $broker = null): MessageProducer
     {
         return $this->asyncPublish($broker);
     }
 
     /** Return a ConsumerBuilder instance.  */
-    public function consumer(array $topics = [], string $groupId = null, string $brokers = null): ConsumerBuilder
+    public function consumer(array $topics = [], ?string $groupId = null, ?string $brokers = null): ConsumerBuilder
     {
         if ($this->shouldFake) {
             return Kafka::fake()->consumer(

src/Logger.php

@@ -31,7 +31,7 @@ public function __construct()
     }
 
     /** Log an error message. */
-    public function error(Message $message, Throwable $e = null, string $prefix = 'ERROR'): void
+    public function error(Message $message, ?Throwable $e = null, string $prefix = 'ERROR'): void
     {
         $this->logger->error("[{$prefix}] Error to consume message", [
             'message' => $message,

src/Message/Message.php

@@ -13,7 +13,7 @@ class Message extends AbstractMessage implements Arrayable, ProducerMessage
 {
     /** Creates a new message instance.*/
     #[Pure]
-    public static function create(string $topicName = null, int $partition = RD_KAFKA_PARTITION_UA): ProducerMessage
+    public static function create(?string $topicName = null, int $partition = RD_KAFKA_PARTITION_UA): ProducerMessage
     {
         return new self($topicName, $partition);
     }

src/Producers/Builder.php

@@ -39,7 +39,7 @@ public function __construct(
     }
 
     /** Return a new Junges\Commit\ProducerBuilder instance. */
-    public static function create(string $broker = null): self
+    public static function create(?string $broker = null): self
     {
         return new Builder(
             broker: $broker ?? config('kafka.brokers')