Variable KafkaMskEventSchemaConst
KafkaMskEventSchema: ZodObject<
extendShape<
{
bootstrapServers: ZodOptional<
ZodNullable<ZodEffects<ZodString, string[], string>>,
>;
records: ZodRecord<
ZodString,
ZodArray<
ZodObject<
{
headers: ZodArray<
ZodRecord<
ZodString,
ZodEffects<ZodArray<(...), (...)>, string, (...)[]>,
>,
"many",
>;
key: ZodEffects<ZodString, string, string>;
offset: ZodNumber;
partition: ZodNumber;
timestamp: ZodNumber;
timestampType: ZodString;
topic: ZodString;
value: ZodEffects<ZodString, string, string>;
},
"strip",
ZodTypeAny,
{
headers: Record<string, string>[];
key: string;
offset: number;
partition: number;
timestamp: number;
timestampType: string;
topic: string;
value: string;
},
{
headers: Record<string, number[]>[];
key: string;
offset: number;
partition: number;
timestamp: number;
timestampType: string;
topic: string;
value: string;
},
>,
"many",
>,
>;
},
{ eventSource: ZodLiteral<"aws:kafka">; eventSourceArn: ZodString },
>,
"strip",
ZodTypeAny,
{
bootstrapServers?: null | string[];
eventSource: "aws:kafka";
eventSourceArn: string;
records: Record<
string,
{
headers: Record<string, string>[];
key: string;
offset: number;
partition: number;
timestamp: number;
timestampType: string;
topic: string;
value: string;
}[],
>;
},
{
bootstrapServers?: null
| string;
eventSource: "aws:kafka";
eventSourceArn: string;
records: Record<
string,
{
headers: Record<string, number[]>[];
key: string;
offset: number;
partition: number;
timestamp: number;
timestampType: string;
topic: string;
value: string;
}[],
>;
},
> = ...
Zod schema for Kafka event from MSK