【发布时间】：2022-01-18 22:24:39
【问题描述】：
我在函数式编程模型中使用 kafka 和 spring cloud stream。 我想使用响应式 api
所以我有一个函数 bean，它接受 Flux 并返回 Flux 返回的通量在单独的类中创建
我是否需要订阅才能激活新的/返回的助焊剂？
【问题讨论】：
标签： apache-kafka spring-cloud-stream reactive-streams
【发布时间】：2022-01-18 22:24:39
【问题描述】：
如果我理解正确，那将无法正常工作。 “流式案例”的期望是您的函数将操作添加到传入的通量并返回它。框架将订阅您的函数返回的内容并开始流。因此，如果您创建 Flux 的新实例，它将无法工作。 我的意思是设计。 一旦我们有了真正的反应性粘合剂（我们目前还没有），事情就会改变。
【讨论】：
-
我受到github.com/spring-cloud/spring-cloud-stream/blob/main/… 上名为 singleInputMultipleOutputs 的方法的启发。我想在我创建的 2 个新接收器上调用 asFlux() 方法创建 2 个 Flux
-
所以是的，上面的测试和这个github.com/spring-cloud/spring-cloud-function/blob/main/… 让您了解支持的内容。但简而言之，输出应该是输入的导数，否则它将不起作用。也就是说，如果您在您的实现中订阅输入并生成框架将订阅的一些输出，我认为这应该可以工作，但我还没有尝试过。随时提出问题。
-
我明白了……非常感谢