apache-zookeeper

0зной

1ответ

У меня есть Zookeeper демоны, работающие на соответствующих узлах и пытаюсь запустить Кафка брокер, но получаю следующее сообщение об ошибке: FATAL [Kafka Server 13], Fatal error during KafkaServer st

1зной

1ответ

Неспособность создать встроенный брокер Kafka

Я пытаюсь использовать kafka's kafka.zk.EmbeddedZookeeper и kafka.server.KafkaServer, возвращенный kafka.utils.TestUtils/createServer, для запуска сервера kafka для тестирования. Но я попадаю в блокпо

1зной

1ответ

Что произойдет, если мастер и подчиненный не смогут общаться?

Я изучаю модель master-slave в zookeeper. У меня просто вопрос: Что произойдет, если один хозяин и один подчиненный не смогут общаться друг с другом? как мастер не может получить ACK от подчиненного?

1зной

1ответ

Zookeeper настройка кластеров

Привет, я пытаюсь настроить Zookeeper в кластерной среде. Для этого я сделал zoo.cfg как: tickTime=2000 # REQUIRED - This will be the basis of timing events (milliseconds) initLimit=5 # REQU

0зной

1ответ

Топология шторма не запускается

Я запускаю кластер Storm v1.0.1 с 1 nimbus и 4 узлами супервизора. У меня есть 2 узла zookeeper. Когда я пытаюсь запустить образец Топологии, который должен потреблять от Кафки. Однако после проверки

4зной

2ответ

выборы лидера в зоопарке и Кафке

вопрос меня беспокоил долгое время. Я знаю, что выборы лидера существуют в зоопарке. Предположим, что у нас есть кластер Kafka, связанный с ансамблем Zookeeper. Итак, я понимаю, что в ансамбле есть ли

-2зной

1ответ

Написание Apache Zookeeper как сервис в go

Я хочу написать очень простой (но полностью функциональный) Apache Zookeeper как сервис в go? С чего начать?

1зной

1ответ

Настройка Kafka Multi Node «Необоснованная длина» в журналах Zookeeper

У меня есть настройка нескольких узлов для kafka, все, кажется, работает хорошо и не отображает журналы ошибок, если я не пытаюсь нажимать сообщение одному производителю. Я получаю сообщение: " Bootst