Apache Flink for Streaming Analytics
Cloudera Streaming Analytics (CSA) offers real-time stream processing and streaming analytics powered by Apache Flink.
CSA provides a flexible streaming solution with low latency that can scale to large throughput and state. For streaming analytics, CSA fits into a complete streaming platform augmented by Kafka, Schema Registry, Streams Messaging Manager in the Cloudera stack. CSA offers the needed connectors depending on the chosen sources and sinks. Cloudera Manager and Kafka Metrics Reporter are provided for monitoring these services, and log aggregation solutions are also available to make the process of streaming analytics more efficient. The following illustration shows the CSA architecture with the available source and sink connectors, monitoring and logging options.