gpt4 book ai didi

Spring云流(Kafka)autoCreateTopics不工作

转载 作者:行者123 更新时间:2023-12-03 08:20:00 31 4
gpt4 key购买 nike

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

这是application.properties中的配置

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

这是启动日志

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]

其他细节-

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

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

最佳答案

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

该属性配置 Binder ,使其不会创建主题;它不会设置该消费者属性。

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

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

关于Spring云流(Kafka)autoCreateTopics不工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68132711/

31 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com