在Spring Cloud Stream Kinesis中,将多个流监听到一个@StreamListener中



我有多个Kinesis流需要处理。是否有可能只使用一个@StreamListener方法?

如果有,如何为此配置@StreamListener?

在一个绑定上确实可以有多个目标目的地:

spring.cloud.stream.bindings.input.destination=stream1,stream2,stream3

请参阅相关文档:https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.3.RELEASE/reference/html/spring-cloud-stream.html#binding-属性

目的地

绑定中间件上绑定的目标目的地(例如,RabbitMQ交换或Kafka主题(。如果绑定表示使用者绑定(输入(,则可以将其绑定到多个目的地,并且可以将目的地名称指定为逗号分隔的字符串值。如果没有,则使用实际绑定名称。无法重写此属性的默认值。

从代码的角度来看,没有什么可做的。您的@StreamListener只是在侦听input绑定。其他一切都是由框架为您完成的。

最新更新