【问题标题】:Listen to multiple streams into one @StreamListener in Spring Cloud Stream Kinesis在 Spring Cloud Stream Kinesis 中将多个流监听到一个 @StreamListener
【发布时间】:2020-03-19 09:48:57
【问题描述】:

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

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

【问题讨论】:

    标签: spring-cloud-stream amazon-kinesis


    【解决方案1】:

    你真的可以在一个绑定上拥有多个目标:

    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-properties

    目的地

    绑定中间件上绑定的目标目的地(例如,RabbitMQ 交换或 Kafka 主题)。如果绑定表示消费者绑定(输入),它可以绑定到多个目的地,并且可以将目的地名称指定为逗号分隔的字符串值。如果不是,则使用实际的绑定名称。该属性的默认值不能被覆盖。

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2019-02-05
      • 2019-08-03
      • 2017-01-28
      • 2019-01-23
      • 2019-08-05
      • 2019-04-19
      • 2021-06-07
      • 2019-04-25
      相关资源
      最近更新 更多