您如何保证Spring Kafka[复制]的Kafka主题配置

Question

我有一个配置bean

    @Bean("alertsTopic")
    public NewTopic alertsTopic() {

        return TopicBuilder.name(PORTAL_ALERTS)
            .config(TopicConfig.DELETE_RETENTION_MS_CONFIG, String.valueOf(Duration.ofHours(1).getSeconds() * 1000))
            .compact()
            .build();
    }

然而，当我检查时

./kafka-configs.sh  --bootstrap-server kafka:9092 --describe --topic portal.alerts --all

似乎没有设置我的任何设置。

我假设我可能在放入配置之前无意中创建了主题。我的问题是如何让我的应用程序检测到NewTopic的值与当前的配置匹配，否则会终止应用程序上下文。

或者强制更新。

Answer 1

如果主题已经存在，则KafkaAdmin将进行的唯一修改是增加分区的数量。

对于其他更改，您必须自己使用AdminClient。