Spring 云流 Kafka 在启动时创建了一个奇怪的主题

Question

我在 application.yml 中为我的 Spring 云流 Kafka 进行了以下设置：

spring:
  cloud:
    function:
      definition: userBinding
    stream:
      kafka:
        binder:
          broker: localhost:9092
          replicationFactor: 1
        bindings:
          userBinding-in-0:
            destination: user

并调用以下消费者函数：

@Bean
public Consumer<Message<UserModel>> userBinding() {
    return message -> {
        System.out.println("Received:" + message);
    };
}

出于某种原因，当我启动应用程序时，它会自动创建一个名为 userBinding-in-0 的新主题，而不是使用来自用户主题的消息！

你能告诉我我遗漏了什么或设置不正确吗？

Answer 1

目标是一个常见的属性（不是特定于 Kafka 的）并且不应该在 kafka 节点下。

spring:
  cloud:
    stream:
      bindings:
        userBinding-in-0:
          destination: user

Spring 云流 Kafka 在启动时创建了一个奇怪的主题

Spring cloud stream Kafka creates a weird topic on startup

apache-kafka

spring-cloud-stream

spring-kafka