Pulsar 消费组

搭建 Pulsar 环境，以 MacOS X 为例:

创建 Pulsar 的主题:

打开 ，点击左侧的 “模块” 选项卡，选择添加：

选择 Pulsar 消费组模块:

填写相关参数:

1). Pulsar 服务器地址

2). Pulsar consumer 进程数量

3). Pulsar 的订阅主题

4). MQTT 的消息主题

5). MQTT 的主题服务质量

6). Pulsar 流控阈值 (Pulsar 流控阈值，配置 Pulsar 向消费者发送多少条消息后阻塞 Pulsar Consumer)

7). EMQX 重置流控阈值百分比 (Pulsar 流控阈值重置百分比。此配置让消费者处理完成一定数量的消息之后，提前重置 。 比如， 为 1000， 为 80%，则重置)

资源已经创建完成，现在用Dashboard的websocket工具订阅MQTT的主题 “TestTopic”:

使用pulsar-cli 生产一条消息:

Dashboard的websocket工具接收到了pulsar 生产的消息”hello-pulsar”: