springboot 启动 kafka创建topic不生效

kafka一个坑

大家应该都知道

@Bean
    public NewTopic updateTopic() {
        return new NewTopic(“topic”,6, (short) 2 );
    }

这样就能在项目启动的时候创建一个topic 6个分区 2个副本

但是当你使用配置的方式创建的时候 这里的代码项目启动之后话题并没有创建

这时候加上@Order(0)就能成功创建了
原理没看过 猜测是kafka自动配置的时候是根据容器里面的bean来创建topic的 但是这个bean使用配置方式的话 放入容器的顺序晚于kafka初始化.

纯猜测 有空再研究 或者有没有大佬解释一下

@Configuration
//@Order(0)
public class KafkaInitialConfiguration  {
    //分区数 默认为6 有配置则使用配置
    @Value("${kafka.partitionSizes}")
    private int partitionSizes ;
    //分区数 默认为6 有配置则使用配置
    @Value("${kafka.replicationFactor}")
    private int replicationFactor ;
    @Value("${kafka.topicName}")
    private String topicName ;
    // 如果要修改分区数，只需修改配置值重启项目即可
    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
    @Bean
    public NewTopic updateTopic() {
        return new NewTopic(topicName,partitionSizes, (short) replicationFactor );
    }
}