Ошибка при настройке кластера с несколькими брокерами на локальном компьютере

Question

Использование Kafka в Ubuntu: Зоопарк начал Кафка началась Тема создана Продюсер начал Потребитель начал Сообщения доставляются в порядке от производителя к потребителю

Я создал 2 новых файла server.properties как: server-1.properties as:

broker.id=1
listeners=PLAINTEXT://:9093
log.dir=C:\kafka\kafka-logs-1

server-2.properties as:

broker.id=2
listeners=PLAINTEXT://:9094
log.dir=C:\kafka\kafka-logs-2

Когда я начал новый брокер как:

bin\windows\kafka-server-start.sh config\server-1.properties &

Ошибка получена как:

kafka.common.KafkaException: Socket server failed to bind to 0.0.0.0:9092: Address already in use: bind

Answer 1

Это происходит потому, что добавленные вами брокеры прослушивают порт 9092, который в данный момент используется первым брокером.

В server-1.properties файл нужно добавить

port=9093

и server-2.properties

port=9094

Держите эти строки listeners=PLAINTEXT://:9093, listeners=PLAINTEXT://:9094 закомментированными.

Также убедитесь, что вы используете разные broker.id для каждого экземпляра.

Если вы пытаетесь настроить мультиброкерский кластер Kafka с одним узлом Zookeeper, вы можете найти это видео полезным.