Merge pull request #1862 from falnyr/patch-1

fix: key was missing in kafka record
brefphp · Sep 25, 2024 · a8eaf87 · a8eaf87
2 parents a4b7744 + cffe79f
commit a8eaf87
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/src/Event/Kafka/KafkaRecord.php b/src/Event/Kafka/KafkaRecord.php
@@ -19,6 +19,11 @@ public function __construct(mixed $record)
         $this->record = $record;
     }
 
+    public function getKey(): string
+    {
+        return $this->record['key'];
+    }
+
     public function getTopic(): string
     {
         return $this->record['topic'];

diff --git a/tests/Event/Kafka/KafkaEventTest.php b/tests/Event/Kafka/KafkaEventTest.php
@@ -19,6 +19,7 @@ public function test canonical case()
         self::assertSame(15, $record->getOffset());
         self::assertSame(1545084650987, $record->getTimestamp());
         self::assertSame('Hello, this is a test.', $record->getValue());
+        self::assertSame('SGVsbG8gV29ybGQ=', $record->getKey());
         self::assertSame(
             [
                 'type'           => 'core',

diff --git a/tests/Event/Kafka/kafka.json b/tests/Event/Kafka/kafka.json
@@ -9,6 +9,7 @@
                 "offset":15,
                 "timestamp":1545084650987,
                 "timestampType":"CREATE_TIME",
+                "key": "SGVsbG8gV29ybGQ=",
                 "value":"SGVsbG8sIHRoaXMgaXMgYSB0ZXN0Lg==",
                 "headers":[
                     {