Pulsar Websocket消费消息两种模式

  • Post author:
  • Post category:其他




1. Consumer 端

Concumer 端要求在 URL 中指定租户、命名空间、topic 和订阅者:

ws://broker-service-url:8080/ws/v2/consumer/persistent/:tenant/:namespace/:topic/:subscription

该方式需要ACK消息确认,会记录消费位置,如果没有及时消费消息会有消息积压。

2. Reader 端

Reader 端要求在 URL 中指定租户、命名空间、topic

ws://broker-service-url:8080/ws/v2/reader/persistent/:tenant/:namespace/:topic

该方式也需要ACK消息确认,不会记录消费位置。默认会消费最近的消息,不会有消息积压,适用于实时看板大屏结果展示。

具体信息查看官网文档,地址为:

https://www.bookstack.cn/read/pulsar-2.8.2-zh/f08eb0e59d50abaf.md#Reader%20%E7%AB%AF



版权声明:本文为qq_42575907原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。