Skip to content

Latest commit

 

History

History
28 lines (25 loc) · 1.13 KB

File metadata and controls

28 lines (25 loc) · 1.13 KB

Build Status Hex.pm

Kafka-Insight

This code is for monitoring Kafka offsets What it looks like? You can modify it anyway you want in Grafana, here is just my first version for demo. Consumer offset and mBean monitor

Install

Requirement

  • Kafka 0.10.x
  • Java 8
  • InfluxDB

Compile

mvn clean package

Change the config file

Modify the "application.conf", at least, the below parts need to be modified.

  • kafka.zkAddr, the Zookeeper address
  • kafka.db.influx.url, the InfluxDB address

Deploy

Run the main class "app.KafkaInsight" anyway you want. It is single point for now and will be suffering from single point failure. HA is part of the plan.

Wiki

For the other doc of the code, please refer to Wiki