kaf

> 编程语言

开源

基于 Go 编写的 Apache Kafka 的现代 CLI。

2.4K stars0 点赞0 次浏览

访问官网 GitHub

工具介绍

基于 Go 编写的 Apache Kafka 的现代 CLI。

Kaf

Kafka CLI 受 kubectl 和 Docker 启发

安装

通过源代码安装:

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

通过安装脚本进行安装:

bash

curl https://raw.githubusercontent.com/birdayz/kaf/master/godownloader.sh | BINDIR=$HOME/bin bash

通过 AUR 在 Archlinux 上安装:

yay -S kaf-bin

通过 Homebrew 安装:

bash

brew tap birdayz/kaf
brew install kaf

使用方法

显示工具版本 kaf --version 添加一个没有身份验证的本地 Kafka kaf config add-cluster local -b localhost:9092 从下拉列表中选择集群 kaf config select-cluster 描述和列出节点 kaf node ls 列出主题、分区和副本 kaf topics 描述名为 mqtt.messages.incoming 的指定主题 kaf topic describe mqtt.messages.incoming

组检查

列出消费者群体 kaf 组

描述一个名为 dispatcher 的消费者组 kaf group describe dispatcher 从标准输入中写入给定主题的消息 echo test | kaf produce mqtt.messages.incoming 从一个主题中管道到另一个主题 kaf consume topic-a --output json-each-row -f | kaf produce topic-b --input json-each-row 重要提示: kaf produce 会覆盖输入消息的关键字、分区和所有标头,如果提供了这些信息

kaf group commit dispatcher -t mqtt.messages.incoming --offset latest --all-partitions

将偏移设置为最旧的值