【问题标题】: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 框架,它提供了完成你需要的所有必要的钩子,但需要更多的配置细节。