PubSub+ lets you link applications and datastores across multiple cloud and on-premises environments without unwieldy adapters or bridges. PubSub+ keeps bandwidth consumption low by using fine-grained topic filtering to deliver exactly and only the events required. For example, if you’re using Kafka to aggregate log data and perform offline analytics on it, but want to use a real-time analytics service running in the cloud to promote products based on sentiment analysis or real-time weather conditions, PubSub+ can take the event stream from Kafka and route a filtered set of information to the analytics engine.
PubSub+ supports MQTT connectivity at massive scale, able to establish reliable, secure, real-time communications with tens of millions of devices or vehicles so you can collect data and hand it off to Kafka for aggregation or analytics. Since PubSub+ can also stream events via other popular open protocols and APIs, you can stream events from all of your applications, running in all kinds of cloud and on-premises environments, to Kafka via the same Source Connector.
In addition to supporting the inbound aggregation of events from millions of connected devices, PubSub+ supports bi-directional messaging and the unique addressing of millions of devices through fine-grained filtering. For example, with Solace and Kafka working together you could send a tornado warning alert to a specific vehicle, or all vehicles in or approaching the affected area. The Sink Connector allows PubSub+ to send record events placed in a single Kafka topic to whatever vehicles satisfy a given condition or topic, whether that’s as general as being in the tri-county area or as specific as a single vehicle.