1. 基本信息
| 项目 | 内容 |
|---|---|
| 名称 | developing-kafka-java-client-confluentinc-agent-skills |
| 作者/维护者 | Confluent, Inc.（官方，confluentinc 组织账号） |
| 来源链接 | https://github.com/confluentinc/agent-skills/tree/main/skills/developing-kafka-java-client |
| 许可证 | Apache-2.0（GitHub API 获取，仓库级） |
| GitHub Stars | 41（整个 confluentinc/agent-skills 合集仓库；该数字反映合集整体热度，不代表本子技能自身热度，GitHub API 获取） |
| Forks | 4（同上，合集整体，GitHub API 获取） |
| 最新版本 | metadata.version 1.0.0；本子技能最近一次内容提交 2026-07-16，仓库整体最近一次推送 2026-07-31（GitHub API 获取） |
| 安装方式 | Claude 插件市场一键安装，或 skills CLI 按需安装单个技能（见第 10 章） |
2. 功能介绍与亮点
这是 Confluent 官方发布的 Java Kafka 客户端脚手架技能，用 Apache Kafka 原生 Java 客户端（KafkaProducer/KafkaConsumer/KafkaShareConsumer）生成生产级 Producer/Consumer 项目，并集成 Confluent Schema Registry 序列化。主文档约 3.1 万字节，另配 17 篇参考代码模板（Avro/JSON Schema 双格式的 Producer/Consumer、同步与异步发送两种变体、Maven 与 Gradle 双构建文件、单测模板、Docker Compose 等，合计约 7.9 万字节）与一份结构化评测集（约 1.5 万字节）。支持三种目标环境（Confluent Cloud、本地 Docker、WarpStream）、两种构建工具（Maven 默认 / Gradle）与三种 Schema 格式（Avro 默认 / JSON Schema / Protobuf）。
亮点：
- 强制确认关卡：正文用
<HARD-GATE>标记要求——在明确问清“现有项目还是从零开始”“目标环境”“Producer/Consumer/两者都要”之前不得生成任何代码；即便用户一次性把所有问题都答全了，仍要求先复述理解并等待用户确认才能动笔 - 10 条踩坑对照表：正文收录“agent 常见错误 vs 实际情况”，覆盖 Schema Registry 序列化器
auto.register.schemas默认值为true必须显式关闭、KafkaProducer应只创建一个实例并复用（而非每条消息新建一个）、AvroSpecificRecord类由构建插件在编译期生成而非手写等 Java 生态特有的坑 - Share Consumer API 支持：面向 Kafka 4.x 的“Queues for Kafka”新特性（
KafkaShareConsumer），可让多个消费者实例并发消费同一分区、突破分区数对并行度的限制，并给出对应的确认（acknowledge）语义与集群侧开启步骤 - 明确禁止读取
.properties文件（“NEVER read, open, or display.propertiesfiles”），凭据排障需引导用户自行核对，并要求将该文件加入.gitignore - 自动生成的单元测试使用
MockProducer/MockConsumer与 Mockito，无需真实 Kafka 集群即可运行，技能正文要求实际执行mvn test/gradlew test并在失败时修复生成的代码而非测试
3. 适用场景
所属分类：工程效率与代码质量——技能的产出物是可编译运行的 Java 项目代码与配套单测，围绕“写代码这件事”（面向 Apache Kafka Java 客户端这一具体库的编码指南与脚手架生成），不涉及第三方账号接入或基础设施部署本身。
适合正在用 Java（Maven 或 Gradle 项目）构建 Kafka 生产者/消费者应用的后端工程师：从零搭建带 Schema Registry 的完整项目、给已有应用补上 Schema Registry 集成，或在 Consumer API 与新的 Share Consumer API 之间做选型，都能直接调用。
4. 跨 Agent 兼容性
- Claude Code：原生支持——仓库提供
.claude-plugin/插件清单，/plugin marketplace add与/plugin install一键安装 - Codex：未验证——官方文档提及通用
skillsCLI（npx skills add）“支持多数 agent”，并点名 Cursor、Windsurf，但未点名 Codex - OpenClaw：未验证——SKILL.md 遵循标准 YAML front matter + Markdown 正文格式，理论上可迁移，但仓库文档未点名支持
- Hermes Agent：未验证——同上，未见任何提及
5. 推荐理由
Java 是企业级 Kafka 部署中最常见的客户端语言，但 Avro SpecificRecord 的构建期代码生成、KafkaProducer 的线程安全复用、基于 wakeup() 的优雅关闭模式，以及刚落地不久的 Share Consumer API 语义，都是初中级用户容易写错或漏掉的细节。这份技能把这些坑整理成显式对照表，并用强制确认关卡防止在理解有偏差的情况下过早生成代码，直接命中“写出能编译但暗藏坑”的 Kafka Java 客户端场景。
6. 评分
| 维度 | 分数 | 说明 |
|---|---|---|
| 受欢迎程度 | 7 | 由 Confluent 官方发布——Confluent 由 Apache Kafka 原创作者创立，是 Kafka 流处理生态公认的一线商业厂商；该子技能自身尚无独立于官方发布之外的第三方讨论或引用证据 |
| 可用性 | 8 | 主文档约 3.1 万字节，另配 17 篇可直接复用的参考代码模板与结构化评测集，合计约 12.6 万字节；本地 Docker 路径完全免费、无强制付费依赖；测试自动生成且要求实测跑通；该子技能自 2026-07-16 上线以来仅 1 次提交，且是官方 2026-05-19 正式 GA 之后补充的技能而非首发四个旗舰技能之一 |
| 安全性 | 9 | 参考目录下 17 个文件逐一核验，均为 Java 代码模板 / 构建脚本（pom.xml/build.gradle）/ Docker Compose / Markdown / Schema 文件，无可疑指令、无混淆代码、无隐蔽外发；正文明确禁止读取 .properties 凭据文件；许可证明确（Apache-2.0） |
综合评分：8.0
7. 跟同类 Skills 相比的优势
| 项目 | 定位 | 与本技能的差异 |
|---|---|---|
| developing-kafka-python-client（同仓库） | 面向 Python 生态、用 confluent-kafka-python 的等价脚手架技能 |
目标语言与生态惯例不同（pip 而非 Maven/Gradle）；两者服务不同技术栈用户，Python 版本额外支持 AsyncIO 模式，Java 版本额外支持 Share Consumer API |
| kafka-streams-programming（同仓库） | 面向 JVM 内嵌流处理库 Kafka Streams 的架构设计、代码生成与生产调试 | 产出的是有状态流处理拓扑而非基础 Producer/Consumer，服务的技术选型层级更高；本技能专注最基础的生产/消费客户端场景 |
| Kafka Development（第三方社区技能，mindrally 发布） | 覆盖 Broker 架构、Producer/Consumer、分区策略、精确一次语义等 Kafka 全栈知识面板 | 定位为通用知识面板，未见针对 Java 客户端的强制确认关卡或逐条踩坑对照表；本技能专精 Apache Kafka Java 客户端库，提供可编译的脚手架、单测与 Share Consumer API 等新特性指导 |
8. 用户评价
该技能目前在第三方平台尚无具名用户评价。
9. 其他补充
同仓库还包含 developing-kafka-python-client、kafka-streams-programming、flink-udf、confluent-cloud-cdc-tableflow、kafka-schema-registry、msk-migration 等面向不同 Kafka/Flink 场景的技能，覆盖从客户端开发、流处理、Schema 治理到基础设施迁移的多个环节，感兴趣的团队可按需在同一仓库中选取安装。
10. 安装使用方式
Claude Code（插件市场）：
/plugin marketplace add confluentinc/agent-skills
/plugin install streaming-skills-plugin@confluent-agent-skills通用（skills CLI，按需安装单个技能）：
npx skills add confluentinc/agent-skills --skill developing-kafka-java-client安装后无需重启 agent；当用户提及 Java Kafka Producer/Consumer、KafkaProducer/KafkaConsumer、Schema Registry 的 Java 集成等意图时会自动触发。
11. 注意事项
- 默认使用 Avro 做 Schema Registry 序列化（生成的
SpecificRecord类由构建插件在编译期从.avsc生成），JSON Schema 与 Protobuf 为可选替代格式 - Share Consumer API（
KafkaShareConsumer）依赖 Kafka 4.x 客户端与集群侧显式开启该特性，本地需执行kafka-features upgrade --feature share.version=1，并非所有 Kafka 部署都已支持 - 面向 Confluent Cloud 部署时，技能依赖用户自行在
.properties中配置真实凭据并自行验证连通性——技能本身不会读取或代为校验凭据 - WarpStream 路径下生产延迟（约 250ms p50）高于标准 Kafka，属预期行为而非配置错误
- 本地开发（Docker Compose + 开源 Kafka）路径完全免费，无需任何付费账号即可走完脚手架到测试通过的全流程