Описание тега apache-zookeeper

Apache ZooKeeper - это распределенная служба, которая обеспечивает хранение информации о конфигурации, именование, синхронизацию, координацию и групповые службы.
1 ответ

Может ли один и тот же экземпляр Zookeeper использоваться рядом служб?

Достаточно ли хороша одна установка Zookeeper для использования кластерами Hadoop Kafka и Storm? Я хочу развернуть все в одной тестовой среде и попробовать поиграть с этими технологиями. Могу ли я использовать для этого одну установку zookeeper? так…
1 ответ

Перезапустите пабер Kubernetes, чтобы очистить постоянный объем

Я работаю с 3 зоокейперами, которые используют постоянный том glusterfs. Все хорошо, если вы впервые запускаете питомец. Одно из моих требований заключается в том, что если petset будет убит, то после перезапуска он все равно будет использовать тот …
01 мар '17 в 19:10
2 ответа

Solrcloud и обработчик импорта данных

Я планирую обновить Solr с одного экземпляра до облачного. В настоящее время у меня есть 5 ядер, и каждое настроено с обработчиком импорта данных. Я развернул веб-приложение вместе с solr.war внутри папки tomcat, которая будет периодически запускать…
22 июн '15 в 11:50
2 ответа

Что случится с Zookeeper, если DNS отключится?

Я изучаю Zookeeper и узнаю, как одним из его самых ценных аспектов является высокая доступность. Недавно у нашего внутреннего DNS возникли проблемы, которые негативно сказались на Zookeeper и других сервисах в зависимости от него. Я не очень разбира…
09 мар '15 в 06:49
2 ответа

Подходит ли Zookeeper для этого сценария?

Вот мое требование. У меня в кластере куча машин (скажем, около 4 - A,B,C,D). Работа А заключается в опросе базы данных на предмет обновлений (поэтому А может искать новые заказы в таблице заказов). Как только A получает обновление, оно проверяет, к…
1 ответ

Не удалось получить информацию о смещении для группы потребителей kafka с помощью CLI zookeeper

Я использую Zookeeper Я использую интерфейс командной строки zookeeper для получения информации о смещении для данной группы потребителей. Ниже работает нормально Command: get /consumers/[ConsumerGroup]/offsets/[TopicName] o/p : 0:1640002 cZxid = 0x…
2 ответа

Можно ли использовать аутентификацию SASL с клиентами Kafka, но не требовать ее для Zookeeper?

Я следил за этим: http://docs.confluent.io/current/kafka/sasl.html Настроить аутентификацию SASL для моего кластера Kafka. Я бы хотел, чтобы все мои клиенты проходили аутентификацию у брокеров через SASL. Меня не волнует Кафка<->зоопарк. Причина в т…
11 июл '17 в 13:29
1 ответ

Безопасность про зоопарка

Я столкнулся с проблемой безопасности зоопарка. У меня есть зоопарк и кафка, и я использую sasl для защиты зоопарка. В то время как я обнаружил, что в zkcli есть ошибка, даже если я не предоставляю имя пользователя и пароль sasl, я все равно могу по…
27 мар '18 в 09:51
1 ответ

Каков формат логов zookeeper?

Я пытаюсь понять формат журналов zookeeper, чтобы я мог написать регулярное выражение для этого, но я не смог найти ни одной статьи, что именно отображается в журналах. Ниже приведена строка в журнале от zookeeper . Может кто-нибудь помочь мне, что …
08 авг '17 в 13:01
1 ответ

Изменение лидерства кластера зоопарка, когда лидер умирает

Далеко внизу вы можете найти файлы docker-compose.yml. Предпосылки: Я запускаю 3 сервера zookeeper как кластер, используя docker-compose (docker-compose.yml, 3 zookeepers), затем добавляю 4. один (еще один docker-compose.yml, 1 zookeeper) в кластер.…
4 ответа

Apache Kafka + интеграция с Apache Camel + проблема POC + java.lang.NullPointerException в java.util.Hashtable.put(Hashtable.java:459)

Это мой строитель маршрута. Здесь я пытаюсь вставить данные из моего файла в topic.Later, я прохожу через мой основной метод и использую верблюжий контекст, я запускаю его. Я пробовал несколько кодов, но ни один не помог мне. Я работаю над POC Apach…
3 ответа

В чем различия zookeeper, задач узла журнала и менеджера журнала кворума в hadoop?

Изучая материал на нескольких веб-сайтах и ​​в видеороликах, меня смущают функциональные возможности и различия в назначении трех компонентов hadoop ZooKeeper, Journal Node и Quorum Journal Manager. Может ли кто-нибудь объяснить мне причины изобрете…
25 сен '14 в 12:13
1 ответ

Как читать длинные данные из ZooKeeper в Ruby

Я использую ZK Gem для чтения данных из ZooKeeper. Это хорошо работает, когда я получаю строковые данные в znode, но если это длинные данные, я получаю байтовый массив и не могу преобразовать в длинную переменную. Я пробовал Array#pack, но это не ср…
11 мар '14 в 03:12
0 ответов

Странный вывод из kafka-consumer-groups.sh

У меня есть группа потребителей под названием myconsumergroup, которая появляется при запуске: bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --list &gt; myconsumergroup Я очень уверен, что совершил смещение. Я ожидаю, что это смещение може…
13 дек '16 в 12:55
2 ответа

Как каждый раз запускать ActiveMQ WebConsole на одном и том же сервере?

У меня есть 3 виртуальные машины, каждая из которых работает zookeeper а также activemq, Каждый раз, когда я начинаю ActiveMQ, ActiveMQ WebConsole начинается на другом сервере. Я хочу запускать ActiveMQ WebConsole на одном и том же сервере каждый ра…
14 мар '16 в 15:04
1 ответ

В ZooKeeper Могу ли я использовать async getData() на несуществующем znode?

Даже если я вызвал метод Существует (), я должен также проверить Code.NoNode. Таким образом, я мог бы использовать метод getData() напрямую? Я заметил, что синхронизация getData() вызовет исключение, если узел не существует. Таким образом, получу ли…
06 июн '11 в 07:04
0 ответов

Ошибка, связанная с ZooKeeper при запуске оболочки hbase

После входа в оболочку hbase, появилась следующая ошибка: ОШИБКА: узел /hbase отсутствует в ZooKeeper. Это должно было быть написано мастером. Проверьте значение, настроенное в 'zookeeper.znode.parent'. Может быть несоответствие с настроенным в маст…
29 мар '17 в 07:22
0 ответов

Кафка - могут ли идентификаторы групп потребителей быть настроены на простых потребителей Spring-интеграции?

Можно ли настроить идентификаторы групп потребителей kafka с простыми потребителями весенней интеграции - опцией канала, управляемого сообщениями?Если нет, то это будет наилучшей альтернативой, если одна тема необходима для функционирования как в ка…
3 ответа

"java.net.ConnectException: соединение отказано" в zookeeper

Я установил zookeeper следующим образом: wget http://archive.cloudera.com/cdh/3/zookeeper-3.3.3-cdh3u1.tar.gz Вот мой zoo.cf: # The number of milliseconds of each tick tickTime=2000 # The number of ticks that the initial # synchronization phase can …
13 окт '11 в 14:16
5 ответов

Проблема с балансировкой при чтении сообщений в Кафке

Я пытаюсь читать сообщения на тему Кафки, но не могу прочитать. Процесс завершается через некоторое время, без чтения каких-либо сообщений. Вот ошибка перебалансировки, которую я получаю: [2014-03-21 10:10:53,215] ERROR Error processing message, sto…