我有多个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
绑定。其他一切都是由框架为您完成的。