Burrow
Kafka monitor
A tool for monitoring Apache Kafka consumer lag and providing cluster information
Kafka Consumer Lag Checking
4k stars
129 watching
802 forks
Language: Go
last commit: 4 months ago
Linked from 2 awesome lists
Related projects:
Repository | Description | Stars |
---|---|---|
zalando-incubator/remora | A tool to monitor and track consumer lag in Apache Kafka clusters | 196 |
omarsmak/kafka-consumer-lag-monitoring | A tool to monitor and analyze Kafka consumer lag to ensure real-time data processing. | 50 |
linkedin/kafka-monitor | Automates monitoring of Kafka cluster performance and health using end-to-end pipelines to collect vital statistics | 2,023 |
linkedin/cruise-control | Automates dynamic workload rebalance and self-healing of large-scale Apache Kafka clusters | 2,769 |
ibm/sarama | A Go client library for interacting with Apache Kafka message broker | 11,584 |
confluentinc/confluent-kafka-go | A high-performance Golang client for Apache Kafka | 4,671 |
provectus/kafka-ui | A web-based management interface for Apache Kafka clusters, providing metrics visualization and configuration options. | 9,903 |
morningstar/kafka-offset-monitor | An application to monitor Kafka consumer progress and lag. | 281 |
dibbhatt/kafka-spark-consumer | A tool for consuming messages from Kafka topics using Spark Streaming while maintaining reliability and handling failures | 635 |
obsidiandynamics/kafdrop | A web-based UI for viewing and managing Kafka topics and consumer groups | 5,602 |
jdamick/kafka | A Go implementation of a distributed publish-subscribe messaging system | 129 |
optiopay/kafka | Provides a Go driver for interacting with Apache Kafka | 216 |
travisjeffery/jocko | A fully managed, distributed messaging system implemented in Go. | 4,935 |
linkedin/li-apache-kafka-clients | A wrapper library that adds features to the Apache Kafka vanilla clients, including large message support and auditing. | 133 |
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 |