KafkaEnvelope: {
    parse<T extends ZodType>(data: unknown, schema: T): TypeOf<T>[];
    safeParse<T extends ZodType>(
        data: unknown,
        schema: T,
    ): ParsedResult<unknown, TypeOf<T>[]>;
} = ...

Kafka event envelope to extract data within body key The record's body parameter is a string, though it can also be a JSON encoded string. Regardless of its type it'll be parsed into a BaseModel object.

Note: Records will be parsed the same way so if model is str, all items in the list will be parsed as str and not as JSON (and vice versa)

Type declaration