kaf操作命令

命令"/>

kaf操作命令

文章目录

• 1.安装kaf
• 2.命令
• • Add a local Kafka with no auth
  • Select cluster from dropdown list
  • Describe and List nodes
  • List topics, partitions and replicas
  • Describe a given topic called mqtt.messages.incoming
  • List consumer groups
  • Describe a given consumer group called dispatcher
  • 创建一个topic
  • 发送消息到topic
  • 消费一个topic

1.安装kaf

go install github/birdayz/kaf/cmd/kaf@latest

2.命令

Add a local Kafka with no auth

kaf config add-cluster local -b localhost:19192

Select cluster from dropdown list

kaf config select-cluster

Describe and List nodes

kaf node ls

List topics, partitions and replicas

kaf topics

Describe a given topic called mqtt.messages.incoming

kaf topic describe mqtt.messages.incoming

List consumer groups

kaf groups

Describe a given consumer group called dispatcher

kaf group describe dispatcher

创建一个topic

kaf topic create topic1 -p 1 -r 1

发送消息到topic

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

消费一个topic

kaf consume topic1