5
$\begingroup$

I would like to subscribe to some topic of kafka or mosquitto in distributed system and do an real-time analyze of a data using Mathematica. Mathematica has Channel-Based Communication using Pub/Sub methodology but it looks like strongly depends on Wolftam cloud. Also Mathematica doesn't have connectors to widespread brokers such kafka (see SocketOpen function).

Could you please expalain how to connect to these brokers (or any else) and subscribe to specific topic? Code example would be greater appreciated.

Improve this question
$\endgroup$

1 Answer 1

Reset to default
1
$\begingroup$

For broker that implements the MQTT protocol (mosquitto) Mathematica has undocumented package MQTTLink located in SystemFiles/Links/MQTTLink which works on publishing at least.

Toy example can be found here. Unfortunately, this example works only on publishing with my setup: Fedora 31, Mathematica 12 and mosquitto v.1.6.7 started locally. Related question is here.

Improve this answer
$\endgroup$

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Not the answer you're looking for? Browse other questions tagged or ask your own question.