假设我们在不同的虚拟机中有服务A、B和Kafka Broker。Service_A是生产者，Service_B是消费者。如果Kafka不能处理工作量，那么：a）如何在不停机的情况下进行纵向扩展？还有，B）分区数量是否可以在不停机的情况下实时更改？
lzfw57am1#
这两个问题的答案都是肯定的，但是扩展outKafka（添加代理）不会给现有的主题添加分区;您需要手动调用kafka-reassign-partitions命令，该命令要求代理正在运行。您可能遇到的主要问题是，如果有客户端正在使用代理上的某个分区，而您将其完全移到了另一个代理上。您永远不能减少分区。
kafka-reassign-partitions
1条答案
按热度按时间lzfw57am1#
这两个问题的答案都是肯定的，但是扩展outKafka（添加代理）不会给现有的主题添加分区;您需要手动调用
kafka-reassign-partitions命令，该命令要求代理正在运行。您可能遇到的主要问题是，如果有客户端正在使用代理上的某个分区，而您将其完全移到了另一个代理上。
您永远不能减少分区。