【问题标题】:Different polling delay for different suppliers in Spring Cloud Stream FunctionSpring Cloud Stream Function中不同供应商的轮询延迟不同
【发布时间】:2021-04-29 10:53:53
【问题描述】:

我正在尝试使用 Spring Cloud Function 和 Kafka 实现供应商。我需要一个供应商每 10 秒发布一次,其他供应商每 30 秒发布一次。我可以从文档中看到,我可以使用 spring.cloud.stream.poller.fixed-delay 属性更改延迟。 Reference

但我需要为每个主题设置不同的延迟。有什么办法吗?

【问题讨论】:

    标签: spring-boot spring-kafka spring-cloud-stream spring-cloud-function


    【解决方案1】:

    从 spring-cloud-function 的角度来看,没有任何形式的轮询,因为它不是框架的责任。 从使用 spring-cloud-function 的 spring-cloud-stream 角度来看,确实存在您描述的机制。但是,请记住,spring-cloud-stream 主要旨在支持微服务概念(不是您的通用消息传递框架),并且在微服务中,我们采用做一件事,但在不影响其他人的情况下做好方法。因此,拥有一个以上的供应商类型与这种模式背道而驰。 如果你正在构建一个通用的消息应用程序,那么我建议使用Spring Integration 框架,它提供了完成你需要的所有必要的钩子,但需要更多的配置细节。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2020-05-21
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多