可快速生成适配Kafka或RocketMQ的客户端代码：一、用自然语言生成Kafka生产者/消费者骨架；二、基于YAML配置生成RocketMQ Spring Boot Starter代码；三、从Java类反向提取消息协议并生成双中间件兼容序列化工具；四、通过MCP协议指令协同调度双中间件客户端。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜
如果您需要在开发中快速生成适配Kafka或RocketMQ的消息中间件客户端代码，但缺乏对底层协议、序列化方式及重试机制的深度掌握，则可能是由于SDK版本差异、配置项繁杂或集群参数不明确导致手动编码效率低下。以下是实现该目标的具体方法：
一、通过自然语言指令生成Kafka生产者与消费者骨架
该方法利用WorkBuddy对Apache Kafka Java客户端API的语义理解能力，将业务意图直接映射为可编译运行的代码，自动注入序列化器、分区策略、ACK机制及错误回调逻辑。
1、在WorkBuddy输入框中输入：“生成一个Kafka生产者Java类，使用StringSerializer作为key和value序列化器，目标topic为‘user-event’，启用幂等性并设置retries=3，发送后打印成功日志”
2、追加约束条件：“同时生成对应消费者类，订阅同一topic，使用StringDeserializer，enable.auto.commit设为false，手动提交offset，每处理10条消息调用commitSync()”
3、确认输出代码中是否包含org.apache.kafka.clients.producer.KafkaProducer与org.apache.kafka.clients.consumer.KafkaConsumer的完整初始化流程，以及props.put(“bootstrap.servers”, “localhost:9092”)等必需配置项
4、检查消费者循环体是否包裹在try-catch中，并对WakeupException做显式捕获以支持优雅关闭
二、基于YAML配置模板生成RocketMQ Spring Boot Starter客户端
该方法适用于已定义消息主题、标签、超时时间等元数据的标准化场景，WorkBuddy可解析结构化配置并生成符合Spring Cloud Stream规范的RocketMQ绑定器代码，屏蔽RocketMQ原生Client与Spring生态的适配差异。
1、创建rocketmq-config.yaml文件，内容包含：topic: order-event, tag: paid, group: order-consumer-group, namesrvAddr: 192.168.1.100:9876, sendTimeout: 3000
2、将该YAML文件上传至WorkBuddy工作区，并输入指令：“根据此配置生成Spring Boot 3.x兼容的RocketMQ消费者与生产者Bean配置类，使用@RocketMQMessageListener注解声明监听器，生产者需支持延迟等级3（10s）”
3、验证生成代码是否引入spring-cloud-starter-stream-rocketmq依赖坐标，并在application.yml中自动注入spring.cloud.stream.rocketmq.binder.namesrv-addr字段
4、确认消费者方法签名是否为public void receive(@Payload String message, @Header("TAGS") String tag)，且具备@RocketMQMessageListener(topic = "order-event", consumerGroup = "order-consumer-group")注解
启用该技能，可以在WorkBuddy对话页的右边栏添加一个日历，提供月历视图、日程增删改查、分类标签（开庭/会议/截止日期/个人/研究/其他），支持从对话中提取事件并自动同步到日历。当用户提到"日历""日程""打开日历""添加日程""我的日程""calendar""安排"或询问已记录的日程信息时使用。
三、从现有Java类反向提取消息协议并生成双中间件兼容客户端
该方法针对已有业务实体类（如Order.class），WorkBuddy可识别其字段结构与注解语义，自动生成Kafka Avro Schema与RocketMQ JSON Schema，并配套生成序列化/反序列化工具类，确保跨中间件的数据一致性。
1、将包含Lombok @Data与Jackson @JsonProperty注解的Order.java上传至WorkBuddy
2、输入指令：“分析该类结构，生成Kafka兼容的Avro Schema定义文件schema/order.avsc，并配套生成RocketMQ使用的JSON Schema字符串，要求所有字段必填且price为double类型”
3、检查生成的Avro Schema是否包含namespace: "com.example.msg"与type: "record"声明，且每个field的type与Java原始类型精确匹配
4、确认配套工具类中是否包含KafkaAvroSerializer
四、注入MCP协议指令驱动多中间件客户端协同调度
该方法面向混合消息架构场景，WorkBuddy依据MCP（Model Control Protocol）指令动态组合Kafka与RocketMQ客户端行为，例如将Kafka作为主链路事件总线，RocketMQ作为补偿事务通道，由单一Skill统一编排。
1、在WorkBuddy技能脚本skills/mq-coordinator/SKILL.md中定义MCP action：{"action": "dual-publish", "kafka-topic": "payment-init", "rocketmq-topic": "payment-compensate", "fallback-on-kafka-fail": true}
2、在input_template区域添加变量占位符：{{payload}}用于传入原始JSON消息体，{{trace-id}}用于注入全链路追踪ID
3、执行该Skill时，WorkBuddy将自动调用KafkaProducer.send()，并在catch块中触发RocketMQTemplate.asyncSend()，确保至少一次投递语义
4、验证生成的协调器类是否在finally块中调用producer.close()与rocketMQTemplate.destroy()，防止资源泄漏
