使用 kaf

1.安装kaf

go install github.com/birdayz/kaf/cmd/kaf@latest
1

2.命令

Add a local Kafka with no auth

kaf config add-cluster local -b localhost:19192
1

Select cluster from dropdown list

kaf config select-cluster
1

Describe and List nodes

kaf node ls
1

List topics, partitions and replicas

kaf topics
1

Describe a given topic called mqtt.messages.incoming

kaf topic describe mqtt.messages.incoming
1

List consumer groups

kaf groups
1

Describe a given consumer group called dispatcher

kaf group describe dispatcher
1

创建一个topic

kaf topic create topic1 -p 1 -r 1
1

发送消息到topic

echo '{"time" : "2020-12-18T03:38:39.000Z", "name" : "name1", "value" : 1}' | kaf -b '127.0.0.1:19192' produce topic1
1

消费一个topic

kaf consume topic1
1