From 0fbf3447cef4e12db4f180a5e744783804ff60c0 Mon Sep 17 00:00:00 2001 From: Connor Kirkpatrick Date: Thu, 24 Apr 2025 09:03:19 +0100 Subject: [PATCH] Make key property optional --- packages/parser/src/schemas/kafka.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/packages/parser/src/schemas/kafka.ts b/packages/parser/src/schemas/kafka.ts index 70b5b74edf..eb23e78e3d 100644 --- a/packages/parser/src/schemas/kafka.ts +++ b/packages/parser/src/schemas/kafka.ts @@ -9,9 +9,12 @@ const KafkaRecordSchema = z.object({ offset: z.number(), timestamp: z.number(), timestampType: z.string(), - key: z.string().transform((key) => { - return Buffer.from(key, 'base64').toString(); - }), + key: z + .string() + .transform((key) => { + return Buffer.from(key, 'base64').toString(); + }) + .optional(), value: z.string().transform((value) => { return Buffer.from(value, 'base64').toString(); }),