【发布时间】:2020-03-19 09:48:57
【问题描述】:
我有多个 Kinesis 流需要处理。是否有可能只使用一个@StreamListener 方法?
如果有,如何为此配置@StreamListener?
【问题讨论】:
标签: spring-cloud-stream amazon-kinesis
我有多个 Kinesis 流需要处理。是否有可能只使用一个@StreamListener 方法?
如果有,如何为此配置@StreamListener?
【问题讨论】:
标签: spring-cloud-stream amazon-kinesis
你真的可以在一个绑定上拥有多个目标:
spring.cloud.stream.bindings.input.destination=stream1,stream2,stream3
目的地
绑定中间件上绑定的目标目的地(例如,RabbitMQ 交换或 Kafka 主题)。如果绑定表示消费者绑定(输入),它可以绑定到多个目的地,并且可以将目的地名称指定为逗号分隔的字符串值。如果不是,则使用实际的绑定名称。该属性的默认值不能被覆盖。
从代码的角度来看,没有什么可做的。您的 @StreamListener 只是在收听 input 绑定。其他一切都由框架为您完成。
【讨论】: