Pulsar Consumer Group

Set up the Pulsar environment, taking MacOS X as an example:

Create Pulsar topic:

Open , click the “Modules” tab on the left, and choose to add:

Click “Select”, and then select “Pulsar Consumer Group”:

Fill in the relevant parameters:

1). Pulsar server address

2). The number of Pulsar consumer processes

3). Pulsar’s subscription topic

4). MQTT message subject

5). MQTT topic service quality

6). Pulsar flow control threshold (Pulsar flow control threshold, configure how many messages Pulsar sends to consumers and block Pulsar Consumer)

7). EMQX reset flow control threshold percentage (Pulsar flow control threshold reset percentage. This configuration allows consumers to reset the in advance after processing a certain number of messages. For example, Is 1000, is 80%, then reset)

The resource has been created, now use Dashboard’s websocket tool to subscribe to the MQTT topic “TestTopic”:

Use pulsar-cli to produce a message:

The websocket tool of Dashboard received the message “hello-pulsar” produced by pulsar: