Как обновить факторы репликации для созданных topi c?

Question

Мы создали темы kafka со значением по умолчанию replication-factor как 1, чтобы обновить это, мы добавили свойство spring.cloud.stream.kafka.binder.replication-factor: 3 в application.yaml, которое не имеет отношения к созданным темам в kafka.

версия весеннего облачного потока используется Germantown.SR1

Answer 1

Базовый AdminClient, используемый связывателем и Spring для Apache Кафка для создания / изменения тем не поддерживает изменение коэффициента репликации.

См. этот ответ , чтобы увидеть, как сделать это с помощью инструментов командной строки (kafka-reassign-partitions).