Skip to the content.

Language: :us: - :cn:


KafkaCenter is a unified one-stop platform for Kafka cluster management and maintenance, producer/consumer monitoring, and use of ecological components.

Table of Contents

Why Should I Use KafkaCenter?

You have a Kafka cluster* and want to

All you need is a MySQL DB in the background where KafkaCenter can store its configuration. If you want to use the monitoring functionalities, you additionally need an Elasticsearch installation. Then, just download our Docker image (see HowTo below) and off you go!

* Note: KafkaCenter does not yet support authenticating to a secured Kafka cluster (SASL or OAuth), we’re working on it though.

Main Features

avatar avatar

Application Config

The main application configuration is done in a central file. Have look at our detailed example here.

Getting Started

Important: The application needs a MySQL database to store all configurations. Before you begin, make sure that you have it either installed on the same host or that there’s an instance available somewhere else. The exact location can then be configured via the spring.datasource.url inside the (There is no MySQL service included in the Docker image.)

Resource Dependencies Use
MySQL must Stores all configuration information (users, teams, clusters, etc.)
Elasticsearch (7.0+) optional Stores monitoring information (cluster metrics, consumption lag visualization, etc.)
Email server optional Email notifications (topic requests & approvals, configured consumer alerts)

1. Init

Create database and table

Execute the provided table_script.sql on your MySQL instance to create the database and all necessary tables.

Edit config

Download the provided example and adapt the config to your needs.

2. Run

The following command assumes that you have your adapted inside the same folder:

docker run -d \
  -p 8080:8080 \
  --name KafkaCenter \
  -v ${PWD}/ \ 

Option B: Local

Important: Make sure you have installed a JRE 8 or higher and download the most recent release package.

$ git clone
$ cd KafkaCenter
$ mvn clean package -Dmaven.test.skip=true
$ cd KafkaCenter\KafkaCenter-Core\target
$ java -jar KafkaCenter-Core-2.3.0-SNAPSHOT.jar

3. Access UI

The application UI is published on port 8080. Visit http://localhost:8080 (or insert the IP/URL of the host you deployed on) and log in with the default administrator:user/pw = admin/admin

Building KafkaCenter and/or Contributing Code

We’re happy if you want to play around and build KafkaCenter locally, or even get involved in shaping and developing KafkaCenter further. The Contributing Guidelines will help to get you started.


For more information, see the README in KafkaCenter/docs.
For information about user guide the documentation, see the UserGuide in KafkaCenter/docs/UserGuide
For information about module the documentation, see the Module in KafkaCenter/docs/Module.
For information about kafka connect ui, see docs in KafkaConnectUi.

Note that we open-sourced our tool very recently and did not translate all the documents to English yet. (We are happy about contributions in this area as well if you’re motivated!)


See the separate Changelog.

Questions? Problems? Suggestions?

If you found a bug, want to request a feature or have a question, please create an issue. Try to make sure someone else hasn’t already created an issue for the same topic beforehand.