1. A method, comprising: reading, by a processor, real-time stream data as workloads, each workload including one or more data items from the real-time stream data; determining, by the processor, any deviation in content of the workloads relative to previous content of previous workloads; reporting, by the processor, when a particular deviation exceeds a threshold value to a workload coordinator; and receiving, by the processor, a data distribution map dynamically broadcasted by the workload coordinator, the data distribution map indicates a processing unit to forward the workloads along a distribution path for the workloads where an instance of a next processing node for the workloads can process the workload.