我正在使用adminclient修改现有kafka主题的其他配置。但是我找不到一个方法来改变这个主题的复制因子。有什么方法可以用java改变复制因子吗?
uurity8g1#
使用adminclient当前不可能做到这一点。然而,有一个正在进行的kip,kip-455,它将很快添加这个功能。目前,更改主题的复制因子的推荐方法是使用 kafka-reassign-partitions.sh 工具,请参阅文档中的本节。
kafka-reassign-partitions.sh
1条答案
按热度按时间uurity8g1#
使用adminclient当前不可能做到这一点。然而,有一个正在进行的kip,kip-455,它将很快添加这个功能。
目前,更改主题的复制因子的推荐方法是使用
kafka-reassign-partitions.sh
工具,请参阅文档中的本节。