用途：实现基于 Kafka、RabbitMQ 的事件驱动架构，支持事件溯源、CQRS、发布订阅、死信队列与 Schema Registry 等模式，适用于需要异步通信、解耦生产者与消费者的微服务、高吞吐数据管道、实时分析、电商订单处理或 IoT 数据流等场景；简单同步轮询场景不建议使用。
主要能力：创建 Kafka 主题与分区进行事件流处理；用 Kafka 存储事件实现事件溯源与状态重建；用 CQRS 分离读写模型；用消费者组实现发布订阅扇出；通过死信队列处理失败消息；用 Confluent Schema Registry 校验 Avro 模式。
使用方式：用 Kafka CLI 管理主题，如 kafka-topics.sh --bootstrap-server localhost:9092 --create --topic orders --partitions 3 --replication-factor 2；用 kafka-console-producer.sh 与 kafka-console-consumer.sh 生产消费事件；RabbitMQ 可用 rabbitmqadmin declare exchange name=events type=fanout；也可通过 Kafka REST Proxy 的 /topics/{topic}/messages 以 POST 发送消息，认证使用 $KAFKA_API_KEY。集成时引入 Kafka 客户端库（如 Java 的 kafka-clients:3.0.0），设置 RABBITMQ_URL、schema.registry.url 等环境变量，并可用 Kafka Connect 的 JDBC 源连接数据库。
限制：资料未提供具体收费、价格、平台支持范围与效果数据；实际部署需自行配置集群、凭据与监控（如 JMX 消费者延迟告警）。