Зоопарк для Кафки и Шторма

Question

Я разработал проект, который читает сообщения от Кафки и обрабатывает их в Storm. Тем не менее, я ничего не делал с zookeeper, кроме настройки конфигурации на порт: 2181. Что-нибудь о Zookeeper для реализации в моем проекте или файле yaml Docker? Может быть, он должен быть запущен как ProcessBuilder

Answer 1

Для процесса Kafka требуется настроенный Zookeeper. в server.properties

Шторму также нужен Zookeeper в storm.yaml

Клиенты Kafka выше, 0.9, не требуют настройки Zookeeper. Любой код в топологиях Storm не должен явно использовать Zookeeper без веской причины.

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