如何在spring云数据流上使用自定义处理器？

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-processor</artifactId>
</dependency>

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.messaging.handler.annotation.SendTo;

@EnableBinding(Processor.class)
public class CustomProcessor {

    @StreamListener(Processor.INPUT)
    @SendTo(Processor.OUTPUT)
    public String process(String message) {
        // 自定义处理逻辑
        return "Processed: " + message;
    }
}

spring.cloud.stream.bindings.input.destination=myInput
spring.cloud.stream.bindings.output.destination=myOutput