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

    {
    "eventSource":"SelfManagedKafka",
    "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
    ]
    }
    ]
    }
    ]
    }
    }