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.