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)
其他详情-
我在这个配置中遗漏了什么吗?
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)
归档时间: |
|
查看次数: |
2389 次 |
最近记录: |