Apache Пульсар против Кафки - потребители тянут (опрашивают) сообщения из тем?

Question

Я знаю, что в Кафке потребитель получает сообщения из тем брокера (тянуть)?

У меня такое ощущение, что Pulsar работает так же, учитывая, что receive метод блоков. Но я не могу найти подтверждение. Может кто-нибудь указать мне ссылку или исправить меня?

Спасибо

Answer 1

Документация Pulsar четко объясняет, как работает потребление сообщений:

Источник Pulsar Consumer считывает сообщения из одной или нескольких тем в кластере Apache Pulsar.

Источник Pulsar Consumer подписывается на темы Pulsar, обрабатывает входящие сообщения, а затем отправляет подтверждения обратно в Pulsar после прочтения сообщений.

---

Сообщения могут быть получены от брокеров либо синхронно (син c) или асинхронно (асин c) .

receive метод получает сообщения синхронно . Процесс потребителя будет заблокирован, пока сообщение не станет доступным. Например,

Message msg = consumer.receive();

Асинхронный прием *1022* немедленно вернется со значением типа CompletableFuture, которое завершается, как только новое сообщение становится доступным. Например,

CompletableFuture<Message> asyncMessage = consumer.receiveAsync();