SimpleProcessor.java

package io.my.streams;

import java.util.function.Function;

@In("from-kafka")
@Out("to-http")
public class SimpleProcessor implements Function<String, String> {
    @Override
    public String apply(final String payload) {
        
        // do something...
        
        return "result";
    }
}