ProphetStor Logo® & Kafka Integration

ProphetStor Logo

Apache Kafka, an open-source distributed event streaming platform, is primarily used to build a real-time streaming platform that handles trillions of constant influx of data a day and processes the data pipelines and applications that adapt to the fluctuation of data streams. By using Machine Learning technologies for predictions and analysis, achieves much better performance (reduced latency) with much fewer resources (reduced number of Kafka consumers) and makes implementing autoscaling of Kafka consumers simple and straightforward.

DiagramThe integration workflow


Workload indicators based on message production rate and consumer lag from Kafka.


Modeling and Machine-Learning-based predictions for workloads.


Apply recommendations for the right numbers of consumer replicas.

Benefits from®

Effective workload predictions uses message production rate of a Kafka topic and target KPI metrics such as the desired latency as the key metrics for autoscaling Kafka consumers. Predictions of message production rate give a more accurate indication of real workloads for Kafka consumers.

Cost-effective application deployments integrates the workload metrics, workload predictions, and application KPI in deciding the right number of replicas and achieves more cost-effective application deployments.

Achieving desired performance

Without guessing or experimenting on what metric threshold to set in Kubernetes native HPA, achieves better use of resources for desired performance automatically. dashboard for Kafka Consumers

VideoA presentation in Kafka Summit on why intelligent autoscaling is better than Kubernetes native HPA

VideoHow to configure an application on for autoscaling Kafka consumer

Start for free today and benefit from the values of machine-learning for your Kafka application.

Read More