Можно ли изменить коэффициент репликации существующей темы кафки с помощью Java?

Question

Я использую AdminClient для изменения других конфигураций существующей темы kafka. Но я не могу найти способ изменить фактор репликации в теме. Есть ли способ, которым я могу изменить коэффициент репликации с помощью Java?

Answer 1

В настоящее время это невозможно с использованием AdminClient.Однако в процессе разработки находится KIP, KIP-455 , который вскоре добавит эту функциональность.

На данный момент рекомендуемый способ изменить коэффициент репликации для темы - использоватьkafka-reassign-partitions.sh инструмент, см. Этот раздел в документации.