fluvio::dataplane
pub fn decompose_partition_name( partition_name: &str) -> Result<(String, i32), PartitionError>