Pulsar: Requesting Pulsar to support IoT protocols - STOMP, AMQP, MQTT, WSS
Use case:
In the IoT related use cases, we are using RabbitMQ as the message broker to receive/send messages from IoT devices over the protocols STOMP, AMQP, MQTT, WSS and further integrate with Kafka/Pulsar for streaming processing/data analysis.
Request:
It would be better if Pulsar has a proxy handler for the protocols STOMP, AMQP, MQTT, WSS. It may help millions of projects, especially those that are serving IoT use cases.
PrashantKS
All 6 comments
Hi @PrashantKS thank you for creating the issue.
We have just added kafka protocol support to pulsar via KoP (https://github.com/streamnative/kop). It is
We are also working on adding both AMQP and MQTT to Pulsar through the same protocol handler mechanism. Please stay tuned. It is coming out soon.
sijie
on 26 Mar 2020
My team also is seriously considering Pulsar to replace ActiveMQ 5 (yes, it's way overdue), but we have a lot of STOMP and AMQP clients.
@sijie Does the kop project depend on the streamio platform, or will it run on native Pulsar?
davidlanouette
on 20 May 2020
@davidlanouette No. kop doesn't depend on the streamnative platform. kop is a protocol handler that you can install it natively in your existing Pulsar cluster. Also streamnative platform is just an enterprise version of pulsar with addons.
We are about to release AMQP-on-Pulsar (AoP) and MQTT-on-Pulsar (MoP) in a few weeks.
sijie
on 20 May 2020
@sijie Thanks for the update!
Do you have a link to that repo? I'd be interested in contributing if I can.
davidlanouette
on 21 May 2020
This issue contains too many requests in one. I would suggest to create 4 separate issues (one for each protocol) and close this one. In this case, the issues can be closed as soon as the handler is implemented and we don't have to wait till all other handlers are finished.
vzhikserg
on 25 May 2020
@davidlanouette sorry that I missed this message!
The AoP is available at https://github.com/streamnative/aop. MoP will be also public soon.
@vzhikserg I agree with you. We can create separate issues for the requested protocol handlers and then close this one.
sijie
on 1 Sep 2020
Related issues
lynnmatrix
路
3Comments
MisterTimn
路
3Comments
Tielem
路
3Comments
vcottagiri
路
3Comments
oliverisaac
路
3Comments
Most helpful comment
@davidlanouette No.
kopdoesn't depend on the streamnative platform.kopis a protocol handler that you can install it natively in your existing Pulsar cluster. Also streamnative platform is just an enterprise version of pulsar with addons.We are about to release AMQP-on-Pulsar (AoP) and MQTT-on-Pulsar (MoP) in a few weeks.