使 kinesis 流接受多个消费者

Question

我有一个流“dest”，我想要两个消费者，并且两个流应该使用相同的消息。

但是如果一个流消耗了消息，那么消息就会丢失并且不会转到第二个流。我不想排队，但这里有话题。

我尝试为 2 个不同的流创建 2 个不同的组，但没有帮助。 此处如何配置？

spring:
  cloud:
    stream:
      bindings:
        input:
          group: group1
          destination: dest
          content-type: application/json

spring:
  cloud:
    stream:
      bindings:
        input:
          group: group2
          destination: dest
          content-type: application/json



spring:
  cloud:
    stream:
      bindings:
        output:
          destination: dest
          content-type: application/json

Answer 1

您需要为该用例 input1 和 input2 声明两个不同的绑定：

spring:
  cloud:
    stream:
      bindings:
        input1:
          group: group1
          destination: dest
          content-type: application/json

spring:
  cloud:
    stream:
      bindings:
        input2:
          group: group2
          destination: dest
          content-type: application/json

这样，绑定器将创建两个不同的消费者，因此，它们都将使用来自 Kinesis 流的相同记录。

当然，您需要为每个绑定目标设置两个不同的 @StreamListener 配置。