spring 云流中的内部频道

Question

我开始开发一个 spring 云流项目。我通过@Streamlistener 注释成功地收到了来自 Kafka 的消息。在将消息发送到任何输出通道之前，我必须通过调用外部服务或数据库调用来转换有效负载。我不想从相同的 streamlistener 方法调用外部服务或 DB 方法。我的问题是，我们可以在 spring 云流中创建内部渠道（如 Spring 集成 DSL 流）吗？

Answer 1

是的，你可以。在 Spring Cloud Stream 中，绑定到活页夹的通道将仅 根据您用于通道绑定的活页夹启用。