2017-02-16 2 views

ответ

1

Кафка делает управление этим внутренне и вам не нужно беспокоиться об этом вообще: http://kafka.apache.org/documentation/#basic_ops_leader_balancing

Если вы создаете новую тему, Кафка будет выбрать брокера, основанный на нагрузки. Если в теме есть только один раздел, она будет размещаться только на одном брокере (плюс последователи, если у вас есть несколько реплик), потому что разделы не могут быть разделены на несколько брокеров в Кафке.

Тем не менее, вы можете получить информацию о том, какой брокер принимает какую-либо тему, и вы также можете «переместить» темы и разделы: http://kafka.apache.org/documentation/#basic_ops_cluster_expansion