微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Spring Cloud Stream Kafka 复制因子和运行时保留问题

如何解决Spring Cloud Stream Kafka 复制因子和运行时保留问题

我有一个使用 Kafka 的 Spring Boot 项目。我使用 Spring Cloud Stream Kafka 自动配置对其进行了配置。我想自动创建具有 3 个副本和 1 天保留期的主题。为此,我将复制因子和保留时间.ms 添加到我的 application.yml 中,如下所示:

spring:
  cloud:
    stream:
      kafka:
        binder:
          replicationFactor: 3
        default:
          consumer:
            topic:
              properties:
                retention.ms: 86400000
          producer:
            topic:
              properties:
                retention.ms: 86400000

实际上这些对我来说很好用,主题创建为 3 个副本,保留 1 天,但是当我在应用程序运行时删除一个主题时,这个主题自动创建,没有副本和保留。有谁知道这是什么原因?我应该怎么做才能在运行时创建具有 3 个副本和 1 天保留期的主题

解决方法

将代理的 auto.create.topics.enable 属性设置为 false

https://kafka.apache.org/documentation/#brokerconfigs_auto.create.topics.enable

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。