kafka-consumer-lag-monitoring
Kafka Lag Monitor
A tool to monitor and analyze Kafka consumer lag to ensure real-time data processing.
Client tool that exports the consumer lag of Kafka consumer groups to Prometheus or your terminal
50 stars
3 watching
13 forks
Language: Kotlin
last commit: almost 2 years agoLinked from 1 awesome list
cloud-nativeconsumer-laggraal-nativegraalvm-native-imagegrafanagrafana-dashboardjavakafkakafka-consumerkotlinkuberneteslagmetricsmonitoringmonitoring-toolnativeprometheusprometheus-exporter
dharmeshkakadia/awesome-kafkaRelated projects:
| Repository | Description | Stars |
|---|---|---|
 zalando-incubator/remora | A tool to monitor and track consumer lag in Apache Kafka clusters | 196 |
 morningstar/kafka-offset-monitor | An application to monitor Kafka consumer progress and lag. | 281 |
 linkedin/kafka-monitor | Automates monitoring of Kafka cluster performance and health using end-to-end pipelines to collect vital statistics | 2,023 |
 streamthoughts/kafka-monitoring-stack-docker-compose | Provides Docker Compose files to deploy a comprehensive Apache Kafka monitoring stack with Prometheus and Grafana. | 136 |
 lwolf/konsumerator | Automates management and resource allocation for Kafka consumers in Kubernetes clusters. | 22 |
 systemcraftsman/strimzi-kafka-cli | A command-line tool to manage Apache Kafka clusters and resources in Kubernetes environments. | 82 |
 mre/kafka-influxdb | A Kafka consumer for InfluxDB that buffers metric data during high loads and enables reliable sending of metrics from remote locations. | 216 |
 grantneale/kafka-lag-based-assignor | A Kafka consumer group assignor that aims to distribute lag evenly across consumers by balancing partitions based on lag levels. | 12 |
 dibbhatt/kafka-spark-consumer | A tool for consuming messages from Kafka topics using Spark Streaming while maintaining reliability and handling failures | 635 |
 rayokota/kwack | In-memory analytics tool for Kafka data using DuckDB | 85 |
 icemachined/kafka-kotlin-native | A Kafka client library for building high-performance and reliable applications using Kotlin Native. | 51 |
 rahulsinghai/jmeter-backend-listener-kafka | Enables sending JMeter test results to a Kafka server. | 30 |
 line/decaton | A framework for high-throughput, concurrent task processing on Apache Kafka | 337 |
 postfinance/kubenurse | A Kubernetes network monitoring tool that measures request durations, records errors, and exports metrics in Prometheus format. | 419 |
 fgeller/kt | A command-line tool for interacting with Apache Kafka clusters | 947 |