Описание тега apache-pulsar
Apache Pulsar - это распределенная система обмена сообщениями pub-sub с открытым исходным кодом.
0
ответов
Как запустить Spark 2.3 Streaming Pulsar Receiver в Python(PySpark)
Я использую python в качестве языка бэкэнда и хочу запустить spark в качестве приемника потоковых данных от Pulsar. Все, что я нашел, это. Похоже, в настоящее время поддерживается только Java. Можно ли заставить его работать в python (т.е. pyspark)?…
10 апр '18 в 15:26
0
ответов
apache pulsar не удалось найти раздел метаданных req_id: 1 ошибка: 1
При попытке создать производителя с помощью Python API client = pulsar.Client('pulsar://localhost:6650') продюсер = client.create_producer('my-topic2') Я получаю следующую ошибку: ОШИБКА ClientConnection:726 | [127.0.0.1:55616 -> 127.0.0.1:6650] Сбо…
03 мар '19 в 02:20
1
ответ
Apache Pulsar - подтверждение от другого потока
Я раскрутил потребитель Pulsar Java в потоке T1 и передаю сообщения для обработки в поток T2. Безопасно ли подтверждать сообщения от T2? Конкретно звонит consumer.acknowledge(messageId) в случае совместного использования двух потоков хорошо?
26 июн '18 в 06:34
1
ответ
Apache Pulsar против Apache RocketMQ
Apache Pulsar (от Yahoo), похоже, является следующим поколением Apache Kafka. Apache RocketMQ (от Alibaba), похоже, является следующим поколением Apache ActiveMQ. Оба являются открытыми платформами для обмена сообщениями и потоковыми данными. Но ка…
12 июн '18 в 22:58
1
ответ
Является ли создание множества тем с пульсаром хорошим сценарием?
Возможно ли и хороший сценарий с пульсаром для создания темы (или раздела) для каждого хэша на лету и удаления тем (или раздела), когда он больше не используется? Идея состоит в том, чтобы иметь возможность читать данные с одним и тем же хешем упоря…
04 янв '18 в 16:08
1
ответ
Исключение в потоке "main" java.lang.NoClassDefFoundError: org/apache/pulsar/client/api/PulsarClient
Я пытаюсь выполнить программу-производитель и потребитель Apache Pulsar через Java, я установил автономный Apache-Pulsar в виртуальной машине GCP и запустил кластер в автономном режиме. Следующий шаг - сборка maven в Windows Eclipse и тот же JAR-фай…
10 фев '19 в 13:38
0
ответов
В пульсаре, когда я извиняюсь `mvn test`, появляется следующая ошибка:
В моем местном я использую mvn install успешно установлен пульсар. Теперь я хочу извинить все тесты, поэтому я исполняю mvn test, но некоторые ошибки, как следующие. я попробую mvn clean install -DskipTestsтогда exec mvn test, но эта ошибка еще не у…
23 фев '19 в 08:34
3
ответа
Apache пульсар бесконечное удержание
В документации по темам Apache Pulsar говорится, можем ли мы установить политику хранения времени темы на -1 для бесконечного времени хранения на основе, каковы недостатки бесконечного хранения и можем ли мы использовать pulsar в качестве хранилища …
14 мар '18 в 00:53
1
ответ
Как обрабатывать сбой Apache Pulsar Consumer.acknowledgeAsync()?
Я использую Consumer.acknowledgeAsync() для подтверждения сообщений в моем Java-сервисе, и мне было интересно, что произойдет, если подтверждение не получится? Должен ли я повторить операцию несколько раз и отказаться от своего потребителя, когда по…
10 дек '18 в 11:16
4
ответа
Каковы преимущества и недостатки Кафки перед Apache Pulsar
Yahoo разработала Pulsar, систему обмена сообщениями в пабе и сделала ее открытой. Теперь это инкубационный проект Apache. Поскольку Кафка также используется для той же цели. Хочу узнать, основные плюсы и минусы у Кафки над Пульсаром.
05 сен '17 в 06:50
1
ответ
Apache Bookkeeper удалить журнал
В Apache бухгалтер, как мы можем удалить запись журнала в бухгалтерской книге? Если выступ неизменен и не может удалять записи, как пульсар удаляет просроченные сообщения из букмекеров?
19 мар '18 в 16:45
1
ответ
Формат сериализации Джексона JSON от Python
Я пытаюсь создать инструмент, который должен выполнять операции администратора на сервисе Apache Pulsar. По какой-то причине они решили не использовать обычный JSON для параметров, находящихся в теле REST API, вместо этого они, кажется, используют с…
24 апр '18 в 10:39
2
ответа
Как использовать Apache Pulsar для обработки заказанных партий
Рассмотрим следующий пример: В мире существуют десятки тысяч магазинов, в которых следует регистрировать внутренние процессы. Для каждого местоположения магазина порядок внутренних задач процесса должен быть сохранен Глобального списка магазинов нет…
02 мар '19 в 23:31
1
ответ
Не удается установить редактор VI /vim в Docker-контейнере
Здравствуйте все, Я пытаюсь установить vim в моем контейнере с докером pulsar(я вытащил изображение пульсара в моем контейнере докера), у меня есть докер в моем компьютере с Windows. Я использовал две команды Обе команды не удается..... первый: apt-…
05 мар '19 в 07:43
1
ответ
AvroSchema не может быть решена
У меня есть одно сомнение в AvroSchema, я создаю Java-программу, в которой AvroSchema является типом схемы. В этой строке Producer provider = pulsarClient.newProducer(AvroSchema.of(Foo.class)). Topic("test_topic"). Создайте(); Первым параметром мето…
13 мар '19 в 08:39
1
ответ
Репликация темы в Apache Pulsar
Документация по тиражированию в Pulsar не очень наглядна. Мне интересно, как репликация работает подробно и как политики постоянства для пространства имен играют в этом. В документации говорится об этих параметрах bookkeeper-ack-quorom: Количество п…
13 мар '19 в 16:55
2
ответа
Прозрачная потоковая передача и пакетная обработка
Я все еще довольно новичок в мире потоковой и пакетной обработки и пытаюсь понять концепции и речи. Весьма возможно, что ответ на мой вопрос хорошо известен, его легко найти или даже сто раз ответили здесь, в SO, но я не смог его найти. Фон: Я работ…
13 мар '19 в 17:03
2
ответа
Как TTL (время жизни) применяется к пространству имен?
Apache Pulsar имеет функцию TTL, как описано в разделе " Сохранение и истечение срока действия официальной документации". Однако я не могу определить, где в конфигурации указано, как часто выполняется эта проверка. Используя стандарт bin/pulsar stan…
20 мар '19 в 15:32
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
1
ответ
Ошибка во время рукопожатия для авторизации tls клиентом apache pulsar на сервере ubuntu
Я установил Apache Pulsar Standalone v2.3 на Ubuntu 18.04.2 LTS из локального запуска Pulsar. Работает нормально без какой-либо аутентификации. Я попытался настроить сертификат TLS с использованием безопасности-TLS-транспорта и безопасности-TLS-ауте…
03 апр '19 в 10:42