Spring云流(Kafka)autoCreateTopics不工作

Swa*_*nil 2 spring apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

我正在将 Spring Cloud Stream 与 Kafka Binder 一起使用。要禁用自动创建主题,我参考了此内容 - How can I configure a Spring Cloud Stream (Kafka) application to autocreate the topic in Confluence Cloud? 。但是,似乎设置此属性不起作用,框架会自动创建主题。

这是application.properties中的配置

spring.cloud.stream.kafka.binder.auto-create-topics=false
Run Code Online (Sandbox Code Playgroud)

这是启动日志

2021-06-25 09:22:46.522  INFO 38879 --- [pool-2-thread-1] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
    allow.auto.create.topics = true
    auto.commit.interval.ms = 5000
    auto.offset.reset = latest
    bootstrap.servers = [localhost:9092]
Run Code Online (Sandbox Code Playgroud)

其他详情-

  1. Spring启动版本:2.3.12.RELEASE
  2. Spring Cloud Stream版本:Hoxton.SR11

我在这个配置中遗漏了什么吗?

Gar*_*ell 5

spring.cloud.stream.kafka.binder.auto-create-topics=false

该属性配置活页夹,使其不会创建主题;它没有设置消费者属性。

要显式设置该属性,还需设置

spring.cloud.stream.kafka.binder.consumer-properties.allow.auto.create.topics=false
Run Code Online (Sandbox Code Playgroud)