集团财产不工作在春流云？

Question

我使用Spring Stream云来消费Kafka上的消息。当Kafka上的信息产生时，所有的消费者都受到了冲击。

但Kafka的文献表明，通过使用群体，只有一个消费者消费信息。

这是我的消费代码。

@EnableBinding(Sink.class)

public class Consumer2 {


    @StreamListener(target = Sink.INPUT)
    public void consume(String message) {
        System.out.println("33333");

    }

    @StreamListener(target = Sink.INPUT)
    public void consume1(String message) {
        System.out.println("444444");

    }


}
}

这是我的配置，但我的两个方法都调用了：(

spring:
  cloud:
    stream:
      default-binder: kafka
      kafka:
        binder:
          brokers:
            - localhost:9092
      bindings:
        input:
          binder: kafka
          destination: abbas
          content-type: text/plain
          group: input-group-1

        output:
          binder: kafka
          destination: abbas
          group: output-group-1
          content-type: text/plain

Answer 1

在一个实例中，组没有影响。

当运行应用程序的多个实例时，每次输入通道中有新消息时，都会通知所有订阅者。

大多数时候，我们只需要处理一次消息。Spring Cloud Stream通过消费者组实现了这种行为。

要启用此行为，每个使用者绑定都可以使用spring。云流动绑定。。要指定组名称的组属性：

https://www.baeldung.com/spring-cloud-stream第5.4节

Answer 2

使用该配置，您只有1个消费者（SINK.INPUT），而不是2个消费者（StreamListener不是消费者，它是处理入站消息的模型）

这就是为什么Spring将入站消息路由到您的两个@StreamListener使用相同的接收器进行注释的原因。