pulsar开启mqtt和认证

Linux MacBook单机部署Pulsar并开启认证功能

pulsar集群搭建_亲测成功

方式一:官方下载nar包

官方下载地址:
https://github.com/streamnative/mop/releases/

下载对应版本的nar包,如: pulsar-protocol-handler-mqtt-2.8.1.0.nar

放到apache-pulsar-2.8.1/protocols目录下,没有protocols目录就创建一个

方式二:源代码编译

#下载源代码
git clone https://github.com/streamnative/mop.git

cd mop

#切换对应版本分支,如:v2.8.1.0 
git checkout v2.8.1.0 

#使用master分支也可以打包成功, 但是启动报错或其他错误

#编译打包
mvn clean install -DskipTests

#成功编译后,会在mqtt-impl/target/目录下生成nar包

#复制到apache-pulsar-2.8.1/protocols 目录下,没有protocols目录就创建一个
mv mqtt-impl/target/pulsar-protocol-handler-mqtt-2.9.0-SNAPSHOT.nar /Users/liang/software/apache-pulsar-2.8.1/protocols 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

配置Mqtt

添加如下属性,在pulsar配置文件中,
集群配置:conf/broker.conf或单机配置:conf/standalone.conf

vim conf/standalone.conf

messagingProtocols=mqtt
protocolHandlerDirectory=./protocols
#brokerServicePort=6650
mqttListeners=mqtt://127.0.0.1:1883
advertisedAddress=127.0.0.1

#开启代理
mqttProxyEnable=true
mqttProxyPort=5682
1
2
3
4
5
6
7
8
9

启动pulsar

单机启动
bin/pulsar standalone

集群启动
bin/pulsar-daemon start broker
1
2
3
4
5