API Reference
    Preparing search index...
    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

    {
    "eventSource":"aws:kafka",
    "eventSourceArn":"arn:aws:kafka:us-east-1:0123456789019:cluster/SalesCluster/abcd1234-abcd-cafe-abab-9876543210ab-4",
    "bootstrapServers":"b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092,b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",
    "records":{
    "mytopic-0":[
    {
    "topic":"mytopic",
    "partition":0,
    "offset":15,
    "timestamp":1545084650987,
    "timestampType":"CREATE_TIME",
    "key":"cmVjb3JkS2V5",
    "value":"eyJrZXkiOiJ2YWx1ZSJ9",
    "headers":[
    {
    "headerKey":[
    104,
    101,
    97,
    100,
    101,
    114,
    86,
    97,
    108,
    117,
    101
    ]
    }
    ]
    }
    ]
    }
    }