README.md

gafka

Unified multi-datacenter multi-cluster kafka swiss-knife management console powered by golang.

Features

• bash-autocomplete, alias, history supported

Ecosystem

• gk

  Unified multi-datacenter multi-cluster kafka swiss-knife management console.

• zk

  A handy zookeeper CLI that supports recursive query.

• ehaproxy

  Elastic haproxy that sits in front of kateway.

• kateway

  A fully-managed real-time secure and reliable RESTful Cloud Pub/Sub streaming message service.

• kguard

  Kafka clusters body guard that emits health info to InfluxDB.

Install

go get github.com/funkygao/gafka

Usage

$gk
Unified multi-datacenter multi-cluster kafka swiss-knife management console

usage: gk [--version] [--help] <command> [<args>]

Available commands are:
    ?                  FAQ
    brokers            Print online brokers from Zookeeper
    checkup            Health checkup of kafka runtime
    clusters           Register or display kafka clusters
    config             Display gk config file contents
    console            Interactive mode
    consumers          Print high level consumer groups from Zookeeper
    controllers        Print active controllers in kafka clusters
    deploy             Deploy a new kafka broker
    discover           Automatically discover online kafka clusters
    kateway            List/Config online kateway instances
    lags               Display high level consumers lag for each topic/partition
    lszk               List kafka related zookeepeer znode children
    migrate            Migrate given topic partition to specified broker ids
    mount              A FUSE module to mount a Kafka cluster in the filesystem
    offset             Manually reset consumer group offset
    partition          Add partition num to a topic for better parallel
    peek               Peek kafka cluster messages ongoing from any offset
    ping               Ping liveness of all registered brokers in a zone
    sample             Sample code of kafka producer/consumer in Java
    top                Unix “top” like utility for kafka
    topics             Manage kafka topics
    topology           Print server topology and balancing stats of kafka clusters
    underreplicated    Display under-replicated partitions
    zktop              Unix “top” like utility for ZooKeeper
    zones              Print zones defined in $HOME/.gafka.cf
    zookeeper          Monitor zone Zookeeper status by four letter word command

$zk
A CLI tool for Zookeeper

usage: zk [--version] [--help] <command> [<args>]

Available commands are:
    acl        Show znode ACL info
    console    Interactive mode
    create     Create znode with initial data
    dump       Dump permanent directories and contents of Zookeeper
    get        Show znode data
    ls         List znode children
    rm         Remove znode
    set        Write znode data
    stat       Show znode status info
    zones      Print zones defined in $HOME/.gafka.cf

TODO

• display kafka server versions