We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 28841fe commit 68fa1ebCopy full SHA for 68fa1eb
packages/parser/src/schemas/kafka.ts
@@ -9,9 +9,12 @@ const KafkaRecordSchema = z.object({
9
offset: z.number(),
10
timestamp: z.number(),
11
timestampType: z.string(),
12
- key: z.string().transform((key) => {
13
- return Buffer.from(key, 'base64').toString();
14
- }),
+ key: z
+ .string()
+ .transform((key) => {
15
+ return Buffer.from(key, 'base64').toString();
16
+ })
17
+ .optional(),
18
value: z.string().transform((value) => {
19
return Buffer.from(value, 'base64').toString();
20
}),
0 commit comments