用途:在 Micronaut 项目中引入或重构 Kafka 消息能力,覆盖生产者与消费者设计、序列化配置、主题与分区策略,以及重试、死信处理和幂等性等可靠性问题。
主要能力:提供 @KafkaClient 与 @KafkaListener 的设计指导,@Serdeable 序列化配置,主题/分区策略,以及失败处理策略;适用于新增 Kafka、审查现有消费者/生产者、改进重试与死信、配置客户端与监听器或 SerDes 等场景。
使用方式:先阅读 references/514-frameworks-micronaut-kafka.md 并检查当前消息配置,明确投递保证与弹性需求后再改动。约束要求:应用任何改动前必须运行 ./mvnw compile 或 mvn compile;若编译失败立即停止;改进后运行 ./mvnw clean verify 或 mvn clean verify 验证。
限制:资料未提供具体代码示例、版本要求、依赖坐标或性能数据,需以参考文件为准。