我用5个代理建立了一个kafka（0.8.1.1）集群。然后我在kafka集群上创建了一个包含16个分区和2个副本因子的主题。我发现16*2分区只分布在3个代理上（11个在代理1上，10个在代理2上，10个在代理3上）。我怎样才能让他们在5个经纪人而不是3个？
iih3973s1#
你可以用 bin/kafka-preferred-replica-election.sh 如图所示，用于自动选择，或使用 bin/kafka-reassign-partitions.sh 您可以在其中手动指定副本和引线。
bin/kafka-preferred-replica-election.sh
bin/kafka-reassign-partitions.sh
1条答案
按热度按时间iih3973s1#
你可以用
bin/kafka-preferred-replica-election.sh如图所示，用于自动选择，或使用bin/kafka-reassign-partitions.sh您可以在其中手动指定副本和引线。