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: 10 days ago
Linked from 1 awesome list
cloud-nativeconsumer-laggraal-nativegraalvm-native-imagegrafanagrafana-dashboardjavakafkakafka-consumerkotlinkuberneteslagmetricsmonitoringmonitoring-toolnativeprometheusprometheus-exporter
Related 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. | 135 |
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. | 80 |
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 | 79 |
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. | 29 |
line/decaton | A framework for high-throughput, concurrent task processing on Apache Kafka | 335 |
postfinance/kubenurse | A Kubernetes network monitoring tool that measures request durations, records errors, and exports metrics in Prometheus format. | 416 |
fgeller/kt | A command-line tool for interacting with Apache Kafka clusters | 948 |