用途:为 Spring Boot 应用接入 Kafka,将配置写入 application.properties 或 application.yml,可选生成 @Configuration 类,并确保模块类路径上有 spring-boot-starter-kafka 依赖。
前置条件:该技能属于 Spring Agent Toolkit,依赖 Amplicode IntelliJ 插件提供的 Spring MCP 服务器。需先确认工具列表中存在 Amplicode 的 Spring MCP 工具(如 get_project_summary、list_module_dependencies、list_application_properties_files);若没有,则需先安装 Amplicode 插件并在欢迎页点击「Настроить Spring Agent」,再重启 MCP 客户端。若无法安装,需从 https://amplicode.ru/marketplace 安装插件。
主要能力与两种路径:默认路径 A 把全部六个 spring.kafka.* 键写入属性源(bootstrap-servers、consumer.group-id、生产者键/值序列化器、消费者键/值反序列化器),由 KafkaAutoConfiguration 自动创建相关 Bean。路径 B 只把 bootstrap-servers 与 consumer.group-id 写入属性源,并生成 KafkaConfiguration 类,包含四个 Bean:{prefix}ProducerFactory、{prefix}KafkaTemplate、{prefix}ConsumerFactory 与 kafkaListenerContainerFactory。监听容器工厂 Bean 名固定为 kafkaListenerContainerFactory,否则自动配置不会退让,@KafkaListener 会被静默路由到错误的工厂。
使用方式:执行时会先读取对话上下文,再通过 MCP 工具收集工程信息(语言、Boot 版本、主包名、模块依赖、属性文件、已有 Bean),把相关问题合并成一次提问(如生产者键/值类型、消费者组必填、bootstrapServers 默认 localhost:9092、序列化器描述位置),随后写属性并添加依赖,路径 B 还会按模板生成配置类。消费者类型默认与生产者对称;POJO 场景需配置 spring.json.trusted.packages 及默认类型键。
限制:代码仅取自 examples/ 文件,无匹配示例时应停止并询问用户;不删除无关属性;监听工厂返回类型须为 ConcurrentKafkaListenerContainerFactory 且不可为原始类型;KafkaProperties 导入按 Boot 分支区分。资料未提供价格、平台支持范围等信息。