如何利用 Fitten Code 自动生成基于 Kafka 的生产者与消费者代码

使用Fitten Code插件可快速生成Kafka生产者与消费者Java代码：自动适配kafka-clients版本、补全依赖、配置序列化器及关键参数，并提供运行前校验指引。

要在项目中快速生成可运行的 Kafka 生产者与消费者 Java 代码，避免手动拼接配置、漏写序列化器或错配依赖版本，直接借助 Fitten Code 的上下文感知生成能力是最省时可靠的路径。

安装并启用 Fitten Code 插件

打开 VS Code → 点击左侧扩展图标 → 搜索 “Fitten Code” → 点击安装 → 安装完成后点击“重新加载”按钮使插件生效。

确保当前工作区已打开一个 Maven 项目（含 pom.xml），否则插件无法识别工程语言栈和依赖上下文。

【必须关闭其他 AI 代码补全插件】，否则 Fitten Code 的生成指令可能被拦截或响应延迟。

生成生产者代码

在项目 src/main/java 下新建包 com.example.kafka，右键 → “New File”，命名为 ProducerDemo.java。

光标置于空文件内，按下 Ctrl+I（Windows/Linux）或 Cmd+I（macOS）唤出 Fitten Code 指令框，输入：
“生成一个 Kafka 生产者，向 topic ‘test-topic’ 发送字符串消息，使用 StringSerializer，bootstrap.servers 为 localhost:9092，启用 acks=all 和重试机制”

回车确认后，Fitten Code 将自动插入完整 Java 类，含 import 声明、Properties 配置、KafkaProducer 实例化、send 调用及 close() 释放逻辑。

生成代码中会自动适配你 pom.xml 中已声明的 kafka-clients 版本（如 3.6.0），若未声明，则默认插入 3.5.1 以保证兼容性。

生成消费者代码

方法一：在同包下新建 ConsumerDemo.java，光标置入后按 Ctrl+I，输入：
“生成一个 Kafka 消费者，订阅 test-topic，从最早 offset 开始消费，打印每条消息的 topic、partition、offset 和 value，使用 StringDeserializer”

方法二：若需 JSON 支持，在指令末尾追加 “value.deserializer 使用 json，自动反序列化为 Map” —— Fitten Code 会自动引入 jackson-databind 依赖建议，并在代码中注入 value_deserializer lambda 表达式。

生成的消费者类默认启用 auto.offset.reset=earliest 和 enable.auto.commit=false，防止首次运行时跳过历史消息。

补全 Maven 依赖

第一步：将光标移至 pom.xml 的 标签内部，按 Ctrl+I 输入：
“添加 kafka-clients 3.6.0 依赖，同时添加 slf4j-simple 作为日志实现”

第二步：Fitten Code 插入依赖块后，立即执行 Maven → Reload project，确保依赖下载完成。

第三步：检查生成的 ProducerDemo.java 和 ConsumerDemo.java 是否仍有红色波浪线——若有，说明 Fitten Code 推断的包路径与实际 module-info.java 或编译级别不匹配，此时需手动将 import org.apache.kafka.clients.producer.* 改为全限定路径引用，或升级 JDK 至 11+。

第四步：在终端中执行 mvn compile，验证无编译错误。

运行前关键校验

确认本地 Kafka 服务已启动：执行 bin/kafka-server-start.sh config/server.properties（Linux/macOS）或 kafka-server-start.bat configserver.properties（Windows）。

确认 ZooKeeper 已就绪（Kafka 3.3+ 可选，但 Fitten Code 默认按兼容模式生成，仍依赖 ZooKeeper 启动元数据）。

在 ProducerDemo.java 中找到 topic 字符串，将其改为实际存在的 topic 名；若该 topic 尚未创建，需先执行：
bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1

【consumer.group.id 不可重复】：若多个消费者实例共用同一 group.id，将触发分区再均衡，导致消息重复或漏消费；Fitten Code 默认生成随机 group.id，但你应在正式提交前手动改为有意义且唯一的值，例如 “group-order-processor-v1”。