Описание тега curator

НЕ ИСПОЛЬЗУЙТЕ ЭТУ ТЕГ. Используйте [apache-куратор] или [asticsearch-куратор], в зависимости от того, о чем на самом деле ваш вопрос.
1 ответ

Не получено удаление событий на PathChildrenCache

Я использую Apache Curator для обнаружения сервисов, и PathChildrenCache прослушивать события, когда услуга добавлена ​​/ обновлена ​​/ удалена. PathChildrenCache pathCache = new PathChildrenCache(client, "/directory", true); pathCache.getListenable…
0 ответов

Apache Zookeeper Curator Framework с AMQP

Я новичок в AMQP, но я хочу получить опыт работы с AMQP с Curator Framework на Apache Zookeeper, поэтому, пожалуйста, дайте мне знать, если у вас есть ссылка на пример проекта Github и полезная информация, чтобы понять это.
29 июн '16 в 12:35
2 ответа

Как сохранить список строк в одном ZooKeeper znode с помощью куратора

Например, есть путь znode A/B/C/D, Я хотел бы сохранить список строк на этом znode. Очевидно, я мог бы использовать объединение списка строк в одну строку, а затем сериализовать его в байтовый массив следующим образом: curator.create() .creatingPare…
16 янв '16 в 12:36
0 ответов

Apache куратор NPE на сервисе Provide.start()

Я использую Apache Curator discovery version 4.0.0 и получаю этот NPE в ConcurrentHashMap.putVal() при запуске поставщика услуг для получения экземпляра службы. (вроде как этот вопрос, но не на JsonInstanceSerializer). java.lang.NullPointerException…
13 фев '18 в 03:53
1 ответ

Apache Curator (Scala) Новый сеанс при переподключении без изменения состояния LOST

Мы наблюдали следующее поведение и не уверены, является ли это известной ошибкой или просто неправильной конфигурацией или неправильным использованием библиотеки. Использование куратор-фреймворка 2.7.0 библиотеки Scala, zookeeper-3.4.5 Запустите при…
10 июн '15 в 17:12
0 ответов

java - [Apache Curator] Как правильно закрыть куратор

Я пытаюсь реализовать резервную логику для моего соединения с Zookeeper с помощью Apache Curator, в основном у меня есть два набора строк подключения, и если я получаю состояние LOST на моем слушателе состояний, я пытаюсь повторно подключить мой кли…
13 дек '18 в 14:49
1 ответ

Apache Curator - исключение потери соединения Zookeeper, возможная утечка памяти

Я работал над процессом, который непрерывно контролирует распределенный атомный длинный счетчик. Он контролирует каждую минуту, используя следующий класс ZkClientметод getCounter, На самом деле, у меня есть несколько запущенных потоков, каждый из ко…
0 ответов

Получение всех последовательно созданных znodes с помощью куратора

Если я создаю zookeeper znodes, используя CreateMode.PERSISTENT_SEQUENTIAL для набора PATH. String PATH = "/Configuration"; rawLocation = zk.create() .withMode(CreateMode.PERSISTENT_SEQUENTIAL) .forPath(PATH, data.getBytes()); Возможно ли получить в…
14 фев '15 в 11:13
0 ответов

Проблемы с тайм-аутом соединения Zookeeper

Мы используем версию кураторской платформы 2.3.0 для подключения к zookeeper в файле pom. <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.3.0</version&gt…
0 ответов

ApacheCurator распределенная блокировка - производительность

В настоящее время мы оцениваем apache-куратор для случая использования распределенной блокировки. Ниже приведен наш тестовый пример: public class Test { private static CuratorFramework client = CuratorFrameworkFactory.newClient("zook.company.com", n…
24 апр '15 в 16:07
1 ответ

Сохранение данных Apache Zookeeper. Выдерживают ли узлы, созданные с помощью CreateMode.Persistent, полный перезапуск кластера?

Я создаю узлы, используя библиотеку apache curator на окнах, используя CreateMode.Persistent. После полной перезагрузки кластера я замечаю, что иногда присутствуют узлы. В других случаях это не так. Zookeeper гарантирует, что созданные узлы будут со…
03 ноя '14 в 20:43
1 ответ

Путь блокировки Apache Curator

Мы знаем, как создать распределенную общую блокировку с помощью Apache Curator: InterProcessMutex lock = new InterProcessMutex(client,"/my/lock"); Для приведенного выше кода у меня есть два вопроса: 1: Второй параметр - это путь к блокировке (znode)…
24 мар '14 в 21:42
1 ответ

Переиндексировать все ElasticSearch с помощью куратора?

Существует ли рецепт для переиндексации всех индексов ElasticSearch с помощью куратора? Я вижу, что он может переиндексировать набор индексов в один (вариант использования "Ежедневно в месяц"), однако я не вижу ничего, что указывало бы на то, что он…
31 окт '18 в 20:45
2 ответа

Запланированные задачи в кластере с использованием zookeeper

Мы используем Spring для запуска запланированных задач, который отлично работает с одним узлом. Мы хотим запустить эти запланированные задачи в кластере из N узлов таким образом, чтобы задачи выполнялись максимум одним узлом в определенный момент вр…
1 ответ

Кто клиенты ZooKeeper?

Только начал читать Документацию Zookeeper. Читайте, что у zk есть серверы (подписчики + лидер) и клиенты. Кто на самом деле клиенты ZK? Узлы распределенной системы, что это координирует? Также прочитайте это Приложения ZooKeeper работают на тысячах…
1 ответ

Куратор фоновой операции повторной попытки сдался

Мой код такой: String zkAddress = "..."; // example ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client = CuratorFrameworkFactory.builder() .connectString(zkAddress) .retryPolicy(retryPolicy) .build();…
12 июн '16 в 10:43
2 ответа

Apache Curator Lock Рецепты отмены

Я пытаюсь протестировать отзывную блокировку в Apache Curator. У меня есть два потока, которые пытаются получить блокировку. Если первый тест получает блокировку, второй поток может попросить первый поток снять блокировку, чтобы 2-й поток мог ее пол…
1 ответ

Объекты Curator Framework для Zookeeper

Нужно ли создавать отдельные экземпляры фреймворка Curator для каждого из получателей, которые я хочу реализовать в своем проекте? Например, мне нужно создать отдельный экземпляр CuratorFramework для LeaderElection и отдельный экземпляр CuratorFrame…
01 ноя '13 в 07:12
1 ответ

ELK чтение и хранение журналов log4j

У нас есть около 50 серверов, откуда мы получаем log4j журналы. эта папка, в которой log4j записывает, мы были смонтированы на машине, где у нас есть Logstash, который помещает эти журналы в Elasticsearch. Он создает индекс в Elasticsearch с именем …
28 июн '18 в 04:40
1 ответ

Куратор куратора Zookeeper, как ждать синхронизации?

У меня есть сценарий, когда я получаю доступ к Zookeeper через куратор TreeCache. Для моего конкретного случая использования я не беспокоюсь о том, что ансамбль не будет синхронизирован на несколько миллисекунд (достаточно согласованности). Моя проб…
18 сен '16 в 12:29