Data stream processor and method to counteract anomalies in data streams transiting a distributed computing system

Abstract

Various embodiments relate generally to electrical and electronic hardware, computer software and systems for controlling a data stream processor configured to detect and/or resolve anomalies in data streams including message data. In particular, a system, a device and a method may be configured to access multiple data streams and to detect an anomaly, in real-time or in substantially real-time, that is associated with at least one of the data streams accessed by a data stream processor. In some examples, a method can include one or more of receiving message data to facilitate a computerized rental of property, classifying subset of messages, fetching the classified messages to form multiple data streams, accessing the data stream to indemnity a stream characteristic, detecting an anomaly based on an identified stream characteristic, and generating anomaly resolution data to counteract the detected anomaly.