Add message id key name to config (#315)

Author: LabbeAramis

config/kafka.php

@@ -74,4 +74,9 @@
      | The cache driver that will be used
      */
     'cache_driver' => env('KAFKA_CACHE_DRIVER', env('CACHE_DRIVER', 'file')),
-];
+
+    /*
+     | Kafka message id key name
+     */
+    'message_id_key' => env('MESSAGE_ID_KEY', 'laravel-kafka::message-id'),
+];

src/AbstractMessage.php

@@ -51,10 +51,10 @@ public function getKey(): mixed
     /** @throws MessageIdNotSet */
     public function getMessageIdentifier(): string
     {
-        if (! is_string($this->getHeaders()['laravel-kafka::message-id'])) {
+        if (! is_string($this->getHeaders()[config('kafka.message_id_key')])) {
             throw new MessageIdNotSet();
         }
 
-        return $this->getHeaders()['laravel-kafka::message-id'];
+        return $this->getHeaders()[config('kafka.message_id_key')];
     }
-}
+}

src/Consumers/Consumer.php

@@ -443,8 +443,8 @@ private function getConsumerMessage(Message $message): ConsumerMessage
         // First, we set a new unique id that allows us to identify this message. Then
         // we create a new consumer message instance that will be passed as an arg
         // to the consumer class/closure responsible for consuming this message.
-        if (! array_key_exists('laravel-kafka::message-id', $message->headers)) {
-            $message->headers['laravel-kafka::message-id'] = Str::uuid()->toString();
+        if (! array_key_exists(config('kafka.message_id_key'), $message->headers)) {
+            $message->headers[config('kafka.message_id_key')] = Str::uuid()->toString();
         }
 
         return app(ConsumerMessage::class, [
@@ -482,4 +482,4 @@ protected function getLastRestart(): int
     {
         return (int) Cache::driver(config('kafka.cache_driver'))->get('laravel-kafka:consumer:restart', 0);
     }
-}
+}

src/Message/Message.php

@@ -87,7 +87,7 @@ public function getHeaders(): ?array
         // id is already set, then array_merge will override it. It's safe to do it
         // here because this class is used only when we produce a new message.
         return array_merge(parent::getHeaders(), [
-            'laravel-kafka::message-id' => Str::uuid()->toString(),
+            config('kafka.message_id_key') => Str::uuid()->toString(),
         ]);
     }
-}
+}