Apache Pulsar 与 Kafka - 消费者是否从主题中提取（轮询）消息？

Question

我知道在 Kafka 中，消费者从代理主题中提取消息（拉）？

我感觉 Pulsar 的工作方式是一样的，考虑到该receive方法是阻塞的。但我找不到确认。有人可以指出我的参考资料或纠正我吗？

谢谢

Answer 1

Pulsar 的文档清楚地解释了消息消费的工作原理：

Pulsar Consumer 源从 Apache Pulsar 集群中的一个或多个主题读取消息。

Pulsar Consumer 源订阅 Pulsar 主题，处理传入消息，然后在读取消息时将确认发送回 Pulsar。

可以同步（sync）或异步（async）方式从代理接收消息。

receive方法同步接收消息。消费者进程将被阻塞，直到消息可用。例如，

Message msg = consumer.receive();

异步接收将立即返回CompletableFuture一个新消息可用后完成的类型值。例如，

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