Как настроить server.properties для кластеризации в Кафке

Question

Я следил за Kafka Quickstart за «Настройка кластера с несколькими брокерами» на одной машине. (Только для целей тестирования).

Запуск Kafka с тремя файлами свойств работал хорошо. (Я запустил их на одном компьютере для тестирования)

server.properties:

broker.id=0
listeners=PLAINTEXT://:9092

server-1.properties:

broker.id=1
listeners=PLAINTEXT://:9093

server-2.properties:

broker.id=2
listeners=PLAINTEXT://:9094

Теперь я хочу создать кластер из трех машин.

1) Запускаю ли три Zookeeper для трех машин? С таким же портом (2181)? Или запустить только один Zookeeper на одной машине?

2) Когда я запускаю Kafka с server.properties, я знаю, что у меня должен быть свой broker.id для каждой машины. Как насчет части слушателей? Я использую тот же порт?

слушатели = PLAINTEXT: //192.168.0.5: 9092 (машина 1)
слушатели = PLAINTEXT: //192.168.0.6: 9092 (машина 2)
слушатели = PLAINTEXT: //192.168. 0,7: 9092 (машина 3)

Answer 1

1. Количество машин Zookeeper влияет на доступность и надежность обслуживания. Для тестирования достаточно одного. Если три машины, использующие один и тот же порт или разные порты, оба в порядке, потому что есть conf в server.properties:

zookeeper.connect=localhost:2181
# if using three zookeeper machines and different ports, modify it to following
# zookeeper.connect=192.168.0.5:2181,192.168.0.6:2182,192.168.0.7:2183

Тот же порт хорош и рекомендуется. Также убедитесь, что для advertised.listeners указан адрес, который разрешается каждой из машин в кластерах, а также с того места, где будут работать ваши клиенты.