Sample processor and transformer implementation for Kafka using Spring Cloud Stream with functional probramming