Описание тега pulsar
Легкие потоки, CSP и акторы, подобные Erlang, для Clojure.
1
ответ
Quasar/Pulsar lein midje ошибки сборки на Linux
Я пытаюсь установить Пульсар. У меня есть версия lein idf@idf-Satellite-C55t-A ~/Documents/clojure/pulsar $ lein version Leiningen 2.5.0 on Java 1.7.0_72 Java HotSpot(TM) 64-Bit Server VM idf@idf-Satellite-C55t-A ~/Documents/clojure/pulsar $ У меня …
01 дек '14 в 18:09
1
ответ
Maven для Ubuntu ARM64
У меня есть Jetson Tx2, который является Ubuntu Linux ARM64. Я не могу найти бинарный дистрибутив для этого. Является ли мой единственный вариант получить исходный код для Maven 3.3.9, собрать его, а затем собрать Maven 3.5, используя версию 3.3.9? …
14 ноя '18 в 21:23
3
ответа
Агенты / субъекты, подобные конструкциям в clojure, которые работают со всеми сообщениями, полученными после последнего обновления
Какой лучший способ в clojure реализовать что-то вроде актера или агента (асинхронно обновляемая, несогласованная ссылка), который выполняет следующее? получает отправленные сообщения / данные выполняет некоторую функцию над этими данными для получе…
15 окт '14 в 00:47
0
ответов
Исключение в потоке "main" java.lang.NoSuchMethodError: org.apache.pulsar.client.api.PulsarClient.getPartitionsForTopic
Я пытаюсь реализовать "Адаптер Pulsar для Apache Kafka" через Java, и я следую тот же документ с веб-сайта Apache Pulsar https://pulsar.apache.org/docs/en/adaptors-kafka/ Я следую примеру GitHub для реализации https://github.com/apache/pulsar/tree/m…
27 мар '19 в 09:31
0
ответов
Бухгалтеру не удалось определить локальное имя хоста
Я пытаюсь развернуть экземпляр Apache Pulsar в кластере DC/OS, следуя инструкциям из документации Pulsar. По какой-то причине Bookkeeper выдает исключение при запуске: 14:57:02.948 [main] WARN org.apache.bookkeeper.net.DNS - Unable to determine loca…
01 апр '19 в 15:03
1
ответ
В чем разница между пульсаром и кафкой в отношении потребления?
Чтобы получать данные из Kafka, у нас может быть несколько потребителей по теме, полностью отделенных друг от друга. Тогда, что подразумевается под no shared consumption на странице ( https://streaml.io/blog/pulsar-streaming-queuing), которая раздел…
26 апр '19 в 13:22
1
ответ
Pulsar: Ошибка проверки / получения метаданных раздела при подписке на постоянные://public/default/test
У меня сейчас есть docker-compose.yml файл, который вызывает ряд услуг. Одним из таких сервисов является пульсар, а другим - веб-сервер, подключенный через веб-сокет. Когда я поднимаю эти сервисы, контейнер websocket не работает. Это логи говорят: E…
15 май '19 в 14:39
1
ответ
Как Pulsar хранит сообщения нескольких тем в регистрах?
Pulsar использует бухгалтерию в качестве внутреннего хранилища и хранит метаданные темы в managed-ledgers/$namespace/persistent путь зоопарка. На стороне бухгалтера данные хранятся в /data/bookkeeper/ledgers/current дорожка. Имя файла журнала не отр…
31 июл '19 в 10:06
1
ответ
Инструмент командной строки для проверки раздела темы -> отображение букмекерской книги в Pulsar?
Существует ли инструмент командной строки, который может определить соответствие между разделом темы Pulsar и бухгалтерскими книгами? Данные, хранящиеся в zookeeper, находятся в двоичном формате и не могут быть прочитаны напрямую. get /devpulsar01/m…
31 июл '19 в 20:59
1
ответ
Должны ли мы беспокоиться о слишком большом количестве связок в теме Pulsar?
Мы наблюдали следующее предупреждение в нашем кластере Пульсар. Должны ли мы беспокоиться об этом? 18:37:37.165 [pulsar-modular-load-manager-29-1] WARN org.apache.pulsar.brok er.loadbalance.BundleSplitStrategy - Could not split namespace bundle puls…
31 июл '19 в 21:42
0
ответов
Как создать функцию в Apache Pulsar для докера
Шаг 1: Скопируйте банку в контейнер с пульсаром: docker cp name.jar {ID_CONTAINER}:/pulsar/name.jar Шаг 2: Создать функцию в контейнере пульсар: docker exec -it {ID_CONTAINER} bin/pulsar-admin functions create --jar /pulsar/name.jar --className com.…
20 июн '19 в 01:09
1
ответ
Использование диска Apache Pulsar в контейнере
Я запускаю Apache Pulsar в контейнере Docker в standalone Режим. Публикую строки журнала в теме пульсара. Общий размер журналов составляет около 60 ГБ. В контейнере Pulsar не хватает места на диске / диск и должен прекратить работу. Это конфигурация…
18 июн '20 в 09:52
1
ответ
Производитель с именем уже подключен к теме при использовании приложения Pulsar с регистратором Ignite
У меня сложный проект, в котором используется Ignite и установлена Ignite версия log4j2. Я также хотел бы установить приложение Pulsar на log4j2, однако, когда я запускаю приложение, я получаю следующую ошибку: log4j:WARN No appenders could be fou…
28 июл '20 в 11:14
1
ответ
Получение ошибки "Приложение не найдено" для log4j2 при добавлении приложения Pulsar
Я работаю над сложным приложением, использующим версию log4j2 Ignite. Он отлично работает, но когда я пытаюсь добавить Pulsar Appender он выдает ошибку: log4j:WARN No appenders could be found for logger (org.apache.pulsar.shade.io.netty.util.interna…
24 июл '20 в 09:09
1
ответ
Возможно ли, чтобы на Pulsar было несколько продюсеров одной и той же темы?
Я знаю, что вы можете настроить подписку на тему как общую подписку, чтобы позволить нескольким потребителям по одной теме. Можно ли это сделать для нескольких производителей? По какой-то причине, когда я пытаюсь это сделать, я получаю Producer with…
05 авг '20 в 08:27
1
ответ
Как правильно импортировать зависимость Maven, которую я изменил и перестроил в существующий проект?
У меня есть зависимость от Maven, pulsar-log4j2-appender, которую я раздвоил и изменил исходный код, потому что в моем проекте возникали исключения. После изменения исходного кода я запустил mavenpackageкоманда для создания банки и импортирования ее…
06 авг '20 в 06:50
1
ответ
Clojure эквивалент "Actors"
Недавно я изучал Elixir и Akka, и это заставило меня задуматься: а что эквивалентно в Clojure? Я нашел пару сообщений о "сравнении пропускной способности сообщений" об агентах и актерах, но они были сделаны 8 лет назад. Раньше один ответ былagents…
24 дек '19 в 09:06
2
ответа
Как вести трансляцию в Pulsar
Я исследую технологию для нашего кластера. Pulsar выглядит неплохо, но использование больше похоже на систему очередей. Конечно, система массового обслуживания - это хорошо, но у меня есть конкретное требование: широковещательная передача. Мы хотели…
09 мар '20 в 21:17
1
ответ
Установка Apache Pulsar в Windows Docker
Не могли бы вы помочь мне, как установить локальный автономный кластер Pulsar с помощью Windows docker. Я выполнил следующие варианты. Но я не смог получить доступ к пользовательскому интерфейсу Pulsar Порт 8080 уже выделен для какого-то другого про…
08 июн '20 в 09:09
0
ответов
Как настроить ведение журнала в файл для Apache Pulsar в автономном режиме?
Я хочу настроить Apache Pulsar на вывод журнала в файл в автономном режиме. Я запускаю Pulsar в автономном режиме с systemd service с помощью такой команды exec: /var/lib/apache-pulsar/bin/pulsar standalone Теперь конфигурация журнала Pulsar задокум…
11 июн '20 в 14:36