Старт нескольких брокеров в кафке

Question

Начинающий в кафке и слитном пакете. Я хочу запустить несколько брокеров, чтобы использовать тему.Это можно сделать с помощью этого параметра - {'bootstrap.server' : 'ip:your_host,...',}

Этот параметр можно определить в файле конфигурации сервера или в скрипте.

Но как мне их запустить?Если я просто добавляю несколько конечных точек к серверам начальной загрузки, это выдает следующую ошибку:

java.lang.IllegalArgumentException: требование не выполнено: у каждого слушателя должно быть свое имя, слушатели: PLAINTEXT: //:9092, PLAINTEXT: //: 9093

Answer 1

Готово.Я на самом деле упомянул один и тот же порт для производителя и потребителя и, следовательно, была проблема.Настройте брокеров на разные порты и работайте нормально, даже если один брокер выйдет из строя.