Function echo_server 

pub fn echo_server<'a, C>(
    input: KeyedStream<String, EchoMessage, Cluster<'a, C>>,
) -> KeyedStream<String, Value, Cluster<'a, C>>