Function mz_storage::sink::kafka::deserialize_frontier
source ยท fn deserialize_frontier<'de, D>(
deserializer: D,
) -> Result<Antichain<Timestamp>, D::Error>where
D: Deserializer<'de>,
fn deserialize_frontier<'de, D>(
deserializer: D,
) -> Result<Antichain<Timestamp>, D::Error>where
D: Deserializer<'de>,