Variable KafkaSelfManagedEventSchemaConst
KafkaSelfManagedEventSchema: ZodObject<
{
bootstrapServers: ZodOptional<
ZodNullable<ZodPipe<ZodString, ZodTransform<string[], string>>>,
>;
eventSource: ZodLiteral<"SelfManagedKafka">;
records: ZodRecord<
ZodString,
ZodArray<
ZodObject<
{
headers: ZodArray<
ZodRecord<
ZodString,
ZodPipe<ZodArray<ZodNumber>, ZodTransform<string, (...)[]>>,
>,
>;
key: ZodOptional<ZodPipe<ZodString, ZodTransform<string, string>>>;
offset: ZodNumber;
partition: ZodNumber;
timestamp: ZodNumber;
timestampType: ZodString;
topic: ZodString;
value: ZodPipe<ZodString, ZodTransform<string, string>>;
},
$strip,
>,
>,
>;
},
$strip,
> = ...
Zod schema for Kafka event from Self Managed Kafka