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.


Your Answer

By clicking “Post Your Answer”, you agree to our terms of service, privacy policy and cookie policy

Browse other questions tagged or ask your own question.