pub fn resolve_split(
format: &StreamSplitFormat,
metadata: &StreamMetadata,
) -> Result<ResolvedStreamSplit, CamelError>pub fn resolve_split(
format: &StreamSplitFormat,
metadata: &StreamMetadata,
) -> Result<ResolvedStreamSplit, CamelError>