用途：在现有 Java 应用中集成 Kafka 客户端，或从零生成可投产的 Java Kafka 项目，使用 KafkaProducer/KafkaConsumer 配合 Confluent Schema Registry 序列化器。
主要能力：支持三种目标环境（Confluent Cloud、本地 Docker、WarpStream）；两种构建工具（Maven 默认、Gradle）；三种 Schema 格式（Avro 默认、JSON Schema、Protobuf）。可生成生产者、消费者或两者，消费者可选普通 Consumer API 或 Share Consumer API（队列语义，需 Kafka 4.x 客户端与集群侧启用）。
使用方式：先收集需求（是否已有应用、目标环境、组件、发送模式、构建工具、Schema、主题名、消费组等），必须发送确认摘要并等待用户确认后才生成文件。已有项目应就地修改并补充依赖，不另建项目。生成结构含 pom.xml 或 build.gradle、KafkaConfig.java、生产者/消费者类、src/main/avro/value.avsc、测试与 README，本地 Docker 路径另含 docker-compose.yml。
关键约定：始终使用 Schema Registry，默认 Avro；显式注册 Schema 并设 auto.register.schemas=false、use.latest.version=true；复用单个生产者实例；生产者 flush 后 close，消费者用 wakeup 模式优雅关闭；Confluent 序列化器需声明 https://packages.confluent.io/maven/ 仓库。
限制：绝不读取或显示 .properties 文件，只生成 .properties.example 并加入 .gitignore；WarpStream 内置 Schema Registry 仅支持 Avro 与 Protobuf；Share Consumer API 无按键顺序且需逐条确认。具体版本、价格与平台细节以资料为准，其余暂未提供。