用途：面向 Apache Kafka 生态的未授权访问检测与利用，适用于目标开放 9092 端口、Broker 无认证、Schema Registry 或 Kafka Connect 暴露，或需要从 Kafka 窃取消息数据的场景。默认无认证时，任一组件暴露都可能导致消息窃取、凭据泄露甚至命令执行。
主要能力与用法： 服务发现：nmap -sV -p 9092、2181、8081,8083 扫描生态端口；kafka-broker-api-versions.sh --bootstrap-server TARGET:9092 或 kcat -b TARGET:9092 -L 探测连通性与版本。 未授权验证：kafka-topics.sh --list --bootstrap-server TARGET:9092 能列出 Topic 即无认证；echo ruok | nc TARGET 2181 返回 imok 表示 ZooKeeper 未授权。 攻击决策：Broker 无认证则做 Topic 枚举与消息批量导出，可进一步 Offset 重置与消息重放、配置窃取、ACL 篡改；Schema Registry 暴露则窃取 Schema；Kafka Connect 暴露可读取 Connector 配置中的数据库凭据或注入恶意 Connector；ZooKeeper 暴露可读集群元数据与 Broker 配置。 消息窃取：kafka-console-consumer.sh 配合 --from-beginning、--max-messages 导出单 Topic 或循环批量导出所有 Topic；kafka-consumer-groups.sh 查看与管理 Consumer Group、重置 Offset。 Connect 与 Schema Registry：curl http://TARGET:8083/connectors 枚举 Connector，读取 config 提取 password/secret 等敏感字段；POST 创建 FileStreamSinkConnector 实现数据外泄或文件写入；curl http://TARGET:8081/subjects 获取 Schema 与字段定义。
限制与注意：--from-beginning 会拉取全部历史消息，大 Topic 可能产生 GB 级数据，务必配合 --max-messages；Offset 重置属破坏性操作会导致重复消费；创建或删除 Connector 直接影响数据管道；修改 Schema 可能导致消费端反序列化失败；ZooKeeper 四字命令在新版本默认关闭；消息注入可能触发下游业务异常；批量导出需关注磁盘空间。具体收费与平台信息暂未提供。