为什么我的Spring-Cloud-Stream配置会创建多个kafka消费者

Question

这不是一个大问题，但我很好奇一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。

我有一个针对本地Kafka经纪人的非常简单的spring cloud stream消费者设置。这是spring配置

spring:
  cloud:
    stream:
      bindings:
        consumer-in-0:
          destination: test-topic
          group: test-group

以及消费者阶层本身：

@Bean
Consumer<Message<String>> consumer() {
 return message -> System.out.println("Got it: " + message.getPayload());
}

但当我运行应用程序时，我可以看到输出中创建了3个消费者。但是，当我在我的本地代理中检查消费者组成员时，它总是只有一个消费者，并且总是创建的第二个消费者（即使用客户id测试组2）

为了清楚起见，我使用的是Spring Boot版本2.3.4。发布和云依赖关系版本Hoxton。SR10。

以下是pom中的依赖项：

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kafka</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
  </dependency>
<dependencies>

为什么我有3个消费者？为什么第二个是唯一真正倾听Kafka主题的人？

Answer 1

在启动期间，将创建一个临时使用者，以获取有关为主题配置的分区的信息。

第二个消费者是真正的消费者。

如果您在类路径上有执行器（实际上是微米），KafkaBinderMetrics会创建另一个消费者，以便它可以计算延迟。它实际上并没有消耗任何东西。