Kaf: Kafka CLI

kaf-kafka-cli.md

Install Kaf

curl https://raw.githubusercontent.com/infinimesh/kaf/master/godownloader.sh | BINDIR=$HOME/bin bash
kaf config add-cluster local -b localhost:9092
kaf config select-cluster

Start Zookeper and Kafka

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

Create Topic

sudo bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Use Kaf

 kaf node ls

ID    ADDRESS       
0     4winds:9092

kaf topics

NAME   PARTITIONS   REPLICAS   
test   1            1   

kaf topics describe test

NAME   PARTITIONS   REPLICAS   
test   1            1  

 echo "works" | kaf produce test
 echo "{\"values:\": [1,2,3,4,5,6]}" | kaf produce test

kaf consume test

works

{
  "values:": [
    1,
    2,
    3,
    4,
    5,
    6
  ]
}

more on https://github.com/infinimesh/kaf/blob/master/README.md