用途:面向命令行环境提供 Kafka 工具知识,覆盖生产、开发与排障中的消息生产消费、主题与消费组管理、认证配置和集群管理。
主要能力:kcat 支持生产(-P)、消费(-C)、元数据列表(-L)、偏移查询(-Q)、自定义格式化、JSON 输出、压缩、消息头与 acks 配置,并可用 -X 设置 SASL/SSL、mTLS 参数。kcli 面向 Kubernetes,提供 produce、consume、topics list 等子命令。kaf 提供交互式 TUI,可配置集群、浏览主题、重置消费组偏移、管理 Schema Registry。kafkactl 偏管理,支持创建/修改/删除 topic、消费组描述与重置、ACL 与配额管理、分区副本重分配。
使用方式:按平台安装,例如 macOS 使用 brew install kcat、brew install kaf、brew install deviceinsight/packages/kafkactl;kcli 可用 kubectl krew install kcli 或下载二进制。常用命令如 echo "Hello Kafka" | kcat -P -b localhost:9092 -t my-topic,kcat -C -b localhost:9092 -t my-topic -o beginning,kafkactl create topic my-topic --partitions 3 --replication-factor 2。认证通过 -X security.protocol 与 sasl.mechanism 等参数传入。
适用场景:脚本化运维、Kubernetes 原生部署、开发快速探查、生产集群管理、死信队列与消费组延迟监控、多集群复制测试、性能压测与连接排障。
限制:资料未提供具体价格、许可证、性能基准与版本兼容范围;部分功能受工具自身支持范围限制,例如 kcat 不直接管理 ACL 与配额,kcli 仅面向 Kubernetes,kafkactl 的 TUI 能力有限;凭据不建议硬编码,生产建议使用 SSL/TLS 与 SCRAM。