小编her*_*-zh的帖子

Spring Cloud Stream 3.0 存在生产者问题

看了spring cloud stream 3.0的文档,理解了新的用java.util.function.[Supplier/Function/Consumer]来代表生产者、消费和生产、消费者,这个应该是正确的。

但我不了解供应商。

该文档指出,对供应商的轮询用于一致地为供应商生成数据,并且不需要任何程序参与。

但是很多时候,我们需要在特定时间生成数据,例如 Web 请求,而我找不到任何文档或示例。

它可能就像注入 Supplier 对象并调用 get() 方法一样简单,但是如何禁用轮询调用呢?

感谢所有提供信息的人。

spring-cloud-stream spring-cloud-stream-binder-kafka

1
推荐指数
1
解决办法
1415
查看次数