This repository was archived by the owner on Jul 27, 2019. It is now read-only.
- Notifications
You must be signed in to change notification settings - Fork2
Kafka Topic -> Consumer map
License
NotificationsYou must be signed in to change notification settings
ApplauseOSS/ConsumerGraph
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
A small utility to browse Kafka topic-to-consumer relationships. Each node is collapsible.
NOTE - This supports installations with offsets stored in Kafka. Offsets stored in Zookeeper are not supported.
Graph View:
Tree View:
The following env vars are recognized by the image:
| Name | Default | Description | Example |
|---|---|---|---|
CLUSTER_NAME | Kafka | The name of this Kafka cluster. Displayed on the root node. | kafkaone |
PORT | NONE | The port the server runs on. | 8080 |
KAFKA_BROKERS | NONE | A list of Kafka brokers for the cluster to monitor. | kafkaone.server.com:9092,kafkatwo.server.com:9092 |
CONSUMER_TIMEOUT | NONE | The time the consumer spends waiting in poll() if data is not available, in milliseconds. | 30000 |
TOPIC_FILTER | NONE | A regex to filter out topics. | _.*|console.* |
CONSUMER_FILTER | NONE | A regex to filter out consumers. | _.*|console.* |
LOG_LEVEL | NONE | The logging level for log4j, [ALL | DEBUG | ERROR | FATAL | INFO | OFF | TRACE | WARN] | INFO |
UI_STYLE | NONE | The UI style to use, [graph | tree] | tree |
ConsumerGraph is available onDocker hub.
The easiest way to build it is via the build script. You will need Maven and Docker installed.
$ ./build.sh$ docker run -p 9913:9913 \ -e PORT=9913 \ -e CLUSTER_NAME=kafka_one \ -e KAFKA_BROKERS=172.27.24.93:9092 \ -e TOPIC_FILTER="_.*|console.*" \ -e LOG_LEVEL=INFO \ -e UI_STYLE=tree \ -e CONSUMER_TIMEOUT=30000 \ consumergraphYou can build ConsumerGraph with the Maven using the standard lifecycle phases.
This was built/tested using the following versions.
| Component | Version |
|---|---|
| Maven | 3.3.9 |
| Docker | 17.03.0-ce, build 60ccb22 |
| Java | 1.8.0_121 |
| Kafka | 0.10.1.0 |
About
Kafka Topic -> Consumer map
Topics
Resources
License
Contributing
Uh oh!
There was an error while loading.Please reload this page.
Stars
Watchers
Forks
Releases
No releases published
Packages0
No packages published
Uh oh!
There was an error while loading.Please reload this page.