Produce, consume, and manage Kafka topics with lag monitoring and data export. Use when publishing messages, consuming topics, monitoring consumer lag.
生产、消费和管理Kafka主题，支持滞后监控和数据导出。适用于发布消息、消费主题、监控消费者滞后等场景。
引导服务器（默认值：localhost:9092）
bash
scripts/script.sh KAFKA_BOOTSTRAP
Zookeeper地址（默认值：localhost:2181）
bash
scripts/script.sh KAFKA_ZOOKEEPER
Kafka安装目录
bash
scripts/script.sh KAFKA_HOME
列出所有主题及其分区数量
bash
scripts/script.sh topics
创建主题（分区数、副本因子）
bash
scripts/script.sh create-topic <名称> [分区数] [副本数]
主题详细信息描述
bash
scripts/script.sh describe <主题>
生产一条消息（可选键值）
bash
scripts/script.sh produce <主题> <消息> [键]
消费消息（默认：10条，从头开始）
bash
scripts/script.sh consume <主题> [数量] [起始位置]
列出所有消费者组
bash
scripts/script.sh groups
显示消费者组滞后情况
bash
scripts/script.sh lag <组名>
显示连接配置和可用工具
bash
scripts/script.sh config
集群健康状态检查
bash
scripts/script.sh status
删除主题（需确认）
bash
scripts/script.sh delete-topic <主题>
增加主题分区数
bash
scripts/script.sh partitions <主题> <数量>
显示最早/最新偏移量
bash
scripts/script.sh offsets <主题>
该技能支持在以下平台通过对话安装：
帮我安装 SkillHub 和 kafka-1776058923 技能
设置 SkillHub 为我的优先技能安装源，然后帮我安装 kafka-1776058923 技能
skillhub install kafka-1776058923
文件大小: 6.71 KB | 发布时间: 2026-4-15 13:09
