2015-10-30 1 views
2

Я собираюсь установить Kafka для обмена сообщениями с компанией. План состоит в том, чтобы сначала установить кафку на одну огромную машину и, если необходимо, пополнить ее до 4-5 машин (кластер).Как масштабировать один узел Kafka для кластера с несколькими узлами?

У меня мало опыта в kafka. Хотите спросить, можно ли масштабировать, просто изменив параметр в конфигурации брокера и установите zookeeper на недавно подключенном компьютере.

Или как можно грубо сделать это самым простым способом? Более конкретно Cloudera Kafka в CDH.

Благодаря

ответ

4

Для масштабирования Кафку вам придется добавить несколько разделов, чтобы темы, если это необходимо для использования kafka-topics.sh. И чем переназначить разделы вашим новым брокерам, используя kafka-reassign-partitions.sh.

Утилита переназначения автоматически копирует и отправляет ваши данные. Вы можете сделать это для целой темы или для выборочного набора разделов.

Полная документация: here. Просто взгляните на раздел 6.

+0

благодарит за ваш ответ. очень полезно. еще одно запутанное, мне нужно установить kafka пакет kafka_2.10-0.8.2.0.tgz на каждую новую машину в кластере и запустить zk и kafka сервер на них, чтобы они интегрировались в старую запущенную систему kafka? Еще раз спасибо –

+0

Если вы хотите уменьшить масштаб, рекомендуется, чтобы ансамбль ZK был отделен от вашего кластера Kafka. В принципе, как вы сказали, вам придется устанавливать пакет kafka повсюду и указывать на тот же ансамбль ZK. Благодаря ZK все брокеры кафки будут знать, что они находятся в кластере. –