kafka-lag-based-assignor
Partition balancer
A Kafka consumer group assignor that aims to distribute lag evenly across consumers by balancing partitions based on lag levels.
Kafka partition assignor that distributes lag evenly across a consumer group
12 stars
2 watching
5 forks
Language: Java
last commit: over 4 years ago
Linked from 1 awesome list
semantalytics/awesome-kafkaRelated projects:
| Repository | Description | Stars |
|---|---|---|
 cafxx/kafkabalancer | Automates rebalancing of Kafka clusters to minimize workload difference between brokers. | 48 |
 lwolf/konsumerator | Automates management and resource allocation for Kafka consumers in Kubernetes clusters. | 22 |
 omarsmak/kafka-consumer-lag-monitoring | A tool to monitor and analyze Kafka consumer lag to ensure real-time data processing. | 50 |
 confluentinc/kafka-rest | Provides a RESTful interface to interact with a Kafka cluster without using the native protocol or clients | 54 |
 immanuelfodor/kube-karp | Automates high availability and load balancing for Kubernetes clusters by assigning shared virtual IPs to nodes | 124 |
 k8gb-io/k8gb | A Kubernetes-native global load balancing solution with a focus on cloud native qualities and reliability | 899 |
 devshawn/kafka-gitops | Automates Apache Kafka topic and ACL management through code-based configuration | 323 |
 latence-technologies/kafka-ada | An Ada binding for the Apache Kafka C client library, allowing developers to send and receive data from Kafka topics using Ada. | 14 |
 mmolimar/ksql-jdbc-driver | Provides standard access to Apache Kafka via JDBC API. | 87 |
 comcast/mirrortool-for-kafka-connect | A connector for integrating two Kafka clusters using source and sink connectors | 70 |
 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 |
| mmolimar/kafka-connect-fs | A Kafka connector for reading records from file systems and loading them into Kafka. | 110 |
 sngular/kloadgen | A plugin designed to generate load on Kafka topics with support for various data formats and schema registries. | 208 |
 jdamick/kafka | A Go implementation of a distributed publish-subscribe messaging system | 129 |
 morningstar/kafka-offset-monitor | An application to monitor Kafka consumer progress and lag. | 281 |