Публикации по теме 'apache-pulsar'
Как интегрировать Apache Pulsar с FastAPI
Это статья о том, как настроить Apache Pulsar, создавать сообщения и использовать их с помощью FastAPI.
В этой статье не будут показаны все функции Apache Pulsar или FastAPI.
Apache Pulsar и FastAPI — это две мощные технологии, которые в сочетании могут помочь вам создавать чрезвычайно быстрые и масштабируемые API-интерфейсы в реальном времени. Apache Pulsar — это распределенная платформа потоковой передачи с открытым исходным кодом, которая действует как посредник между..
Как функции Apache Pulsar помогают машинному обучению и обработке потоков событий
Функции Apache Pulsar позволяют программистам создавать сценарии автоматической обработки данных потоков событий и сообщений на облачном оборудовании TPU/GPU для поддержки функциональности AI/ML/DL с использованием специально написанного кода на Java, Python или Go. Многие разработчики также используют Apache Pulsar для реализации бессерверных вычислений после запуска AWS Lambda и других платформ на основе Apache OpenWhisk. Функции Pulsar опираются на открытый исходный код и..
Вопросы по теме 'apache-pulsar'
В чем разница между пульсаром и кафкой по потреблению?
Чтобы получать данные из Kafka, у нас может быть несколько потребителей по теме, полностью разделенных. Затем, что означает no shared consumption на странице ( https://streaml.io/blog/pulsar-streaming-queuing ) в чем общие различия между кафкой и...
489 просмотров
schedule
29.11.2021
Могут ли несколько потребителей использовать одно и то же сообщение в теме Pulsar?
Скажем, для этого у вас есть Pulsar Producer для постоянной темы topic1 (пространство имен и клиент не имеют отношения к вопросу).
Допустим, у нас есть несколько потребителей одной и той же темы ( topic1 ) с разными именами подписки.
Можно ли...
1125 просмотров
schedule
17.11.2021
Получение сообщения об ошибке "Нет приложения не найдено" для log4j2 при добавлении приложения Pulsar
Я работаю над сложным приложением, которое использует версию log4j2 Ignite. Он работает отлично, но когда я пытаюсь добавить приложение Pulsar выдает ошибку:
log4j:WARN No appenders could be found for logger...
108 просмотров
schedule
15.09.2021
Как мне определить схему Flink для чтения данных буфера протокола из Pulsar
Я использую Pulsar-Flink для чтения данных из Pulsar во Flink. У меня возникают трудности, когда формат данных - буфер протокола.
На верхней странице GitHub Pulsar-Flink использует SimpleStringSchema . Однако, похоже, официально он не...
128 просмотров
schedule
09.10.2021
Невозможно развернуть Apache Pulsar на AKS. 'значение аннотации selectedNode не установлено'
Это моя первая попытка развернуть Pulsar на AKS v1.15.11.
Я получаю не очень подробные сообщения об ошибках от 2 незапланированных модулей:
Первая внеплановая капсула pulsar-zookeeper-0
[Pod] [pulsar-zookeeper-0] FailedScheduling:...
305 просмотров
schedule
07.03.2022
Как использовать модули Go для загрузки подкаталога в Pulsar
Я пытаюсь использовать клиент pulsar go с модулями go, но не могу импортировать нужную версию.
Создал файл go.mod с зависимостью от Pulsar, а также добавил другие зависимости, раньше я использовал dep, и все было хорошо. Теперь я перешел на...
195 просмотров
schedule
14.03.2022
Публикация в теме с зарегистрированной схемой в Apache Pulsar
Как показано в примере в документах реестра Pulsar Schema
Producer<User> producer = client.newProducer(JSONSchema.of(User.class))
.topic(topic)
.create();
User user = new User(“Tom”, 28);
producer.send(User);
Вы можете...
913 просмотров
schedule
17.04.2022
TimeoutException при попытке запустить коннектор источника Pulsar
Пытаюсь запустить коннектор Pulsar DebeziumPostgresSource .
Это команда, которую я выполняю:
bin/pulsar-admin \
--admin-url https://localhost:8443 \
--auth-plugin org.apache.pulsar.client.impl.auth.AuthenticationToken \
--auth-params...
325 просмотров
schedule
26.06.2022
Как написать простой запрос метрик Pulsar с помощью Prometheus?
Я тоже новичок в Prometheus и Pulsar, но, следуя документам, я пытаюсь отправить простейший запрос, чтобы узнать.
Я просмотрел показатели пространства имен и попытался получить количество подписок. Я также должен упомянуть, что я использую...
132 просмотров
schedule
16.08.2022
Apache Pulsar java.lang.IllegalArgumentException
Я работаю над кластером apache pulsar, и он работал нормально, но по какой-то причине я начал получать следующее сообщение, когда пытаюсь отправить сообщение:
ERROR [id: 0xc5de4911, L:/127.0.0.1:55672 - R:localhost/127.0.0.1:6650] Close connection...
202 просмотров
schedule
10.11.2022
Java-клиент Apache Pulsar, занимающий слишком много памяти (OOM)
Я написал простой клиент Apache Pulsar с загрузкой Spring - производитель pulsar, инициализированный как beans, который будет использоваться в остальном контроллере для публикации входящих сообщений api в Pulsar, и потребитель, который потребляет...
680 просмотров
schedule
12.12.2022
Раковина Apache Pulsar Clickhouse - есть ли промежутки между вставками?
Clickhouse допускает высокопроизводительную запись, но только в том случае, если они выполняются массово и с интервалами (рекомендуется интервал не менее 1 секунды между вставками). В документации к JDBC-коннектору для Clickhouse есть опция...
56 просмотров
schedule
30.07.2023
