spring - Spring Cloud Stream - 使用 Spring Cloud 函数（特别是“Function”）公开为 REST 端点并发布到主题

Question

使用 Spring Cloud Stream - 是否可以使用 Spring Cloud 功能（特别是“功能”）作为休息端点公开并发布到主题 - 如下所示 -

@Bean
  public Function<String,String> postLoginEvent() {
    return valFrmRest -> valFrmRest;
  }

目前，如果我尝试这个，端点没有暴露，我得到 404。作为一种解决方法，我使用 anEmitterProcessor从休息端点获取输入，并单独让供应商返回这个处理器以发布到主题。不确定我要问的内容在技术上是否可行，但这可能是一个非常常见的用例，并且提供开箱即用的功能会很好。有什么想法吗？提前感谢您分享您的意见。

标签： springspring-kafkaspring-cloud-stream

Answer 1

您可以将其作为 REST 端点，然后使用StreamBridgeAPI 以编程方式发布它。请参阅此处的详细信息。

这是一个使用.StreamBridge