baluchicken/kafkahq

Kafka GUI to view topics, topics data, consumers group, schema registry ...

KafkaHQ

Kafka GUI for topics, topics data, consumers group, schema registry and more...

Features

• General
  • Works with modern Kafka cluster (1.0+)
  • Connection on standard or ssl, sasl cluster
  • Multi cluster
• Topics
  • List
  • Configurations view
  • Partitions view
  • Consumers groups assignments view
  • Node leader & assignments view
  • Create a topic
  • Configure a topic
  • Delete a topic
• Browse Topic datas
  • View data, offset, key, timestamp & headers
  • Automatic deserializarion of avro message encoded with schema registry
  • Configurations view
  • Logs view
  • Delete a record
  • Sort view
  • Filter per partitions
  • Filter with a starting time
  • Filter data with a search string
• Consumer Groups (only with kafka internal storage, not with old Zookepper)
  • List with lag, topics assignments
  • Partitions view & lag
  • Node leader & assignments view
  • Display active and pending consumers groups
  • Delete a consumer group
  • Update consumer group offsets to start / end / timestamp
• Schema Registry
  • List schema
  • Create a schema
  • Update a schema
  • Delete a schema
  • View and delete individual schema version
• Nodes
  • List
  • Configurations view
  • Logs view
  • Configure a node
• Authentification and Roles
  • Read only mode
  • BasicHttp with roles per user

Quick preview

• Download docker-compose.yml file
• run docker-compose up
• go to http://localhost:8080

It will start a Kafka node, a Zookeeper node, a Schema Registry, fill with some sample data, start a consumer group and a kafka stream & start KafkaHQ.

Installation

First you need a configuration files in order to configure KafkaHQ connections to Kafka Brokers.

Docker

docker run -d \
    -p 8080:8080 \
    -v /tmp/application.yml:/app/application.yml \
    tchiotludo/kafkahq

• With -v /tmp/application.yml must be an absolute path to configuration file
• Go to http://localhost:8080

Stand Alone

• Install Java 8
• Download the latest jar on release page
• Create an configuration files
• Launch the application with java -Dmicronaut.config.files=/path/to/application.yml -jar kafkahq.jar
• Go to http://localhost:8080

Configuration

Configuration file can by default be provided in either Java properties, YAML, JSON or Groovy files. YML Configuration file example can be found here :application.example.yml

Kafka cluster configuration

• kafkahq.connections is a key value configuration with :
  • key: must be an url friendly string the identify your cluster (my-cluster-1 and my-cluster-2 is the example above)
  • properties: all the configurations found on Kafka consumer documentation. Most important is bootstrap.servers that is a list of host:port of your Kafka brokers.
  • schema-registry: the schema registry url (optional)

Security

• kafkahq.security.default-roles: Roles available for all the user even unlogged user, roles available are :
  • topic/read
  • topic/insert
  • topic/delete
  • topic/config/update
  • node/read
  • node/config/update
  • topic/data/read
  • topic/data/insert
  • topic/data/delete
  • group/read
  • group/delete
  • group/offsets/update
  • registry/read
  • registry/insert
  • registry/update
  • registry/delete
  • registry/version/delete

By default, security & roles is enabled by default but anonymous user have full access. You can completely disabled security with micronaut.security.enabled: false.

If you need a read-only application, simply add this to your configuration files :

kafkahq:
  security:
    default-roles:
      - topic/read
      - node/read
      - topic/data/read
      - group/read
      - registry/read

Basic Auth

• kafkahq.security.basic-auth: List user & password with affected roles
  • username: login of user
    • password: Password in sha256, can be converted with command echo -n "password" | sha256sum
    • roles: Role for current users

Server

• kafkahq.server.base-path: if behind a reverse proxy, path to kafkahq with trailing slash

Kafka admin / producer / consumer default properties

• kafkahq.clients-defaults.{{admin|producer|consumer}}.properties: if behind a reverse proxy, path to kafkahq with trailing slash

Micronaut configuration

Since KafkaHQ is based on Micronaut, you can customize configurations (server port, ssl, ...) with Micronaut configuration. More information can be found on Micronaut documentation

Docker

KafkaHQ docker image support 3 environment variables to handle configuraiton :

• KAFKAHQ_CONFIGURATION: a string that contains the full configuration in yml that will be written on /app/configuration.yml on container.
• MICRONAUT_APPLICATION_JSON: a string that contains the full configuration in JSON format
• MICRONAUT_CONFIG_FILES: a path to to a configuration file on container. Default path is /app/application.yml

Development Environment

A docker-compose is provide to start a development environnement. Just install docker & docker-compose, clone the repository and issue a simple docker-compose -f docker-compose-dev.yml up to start a dev server. Dev server is a java server & webpack-dev-server with live reload.

License

Apache 2.0 © tchiotludo