用途:作为 Apache Kafka 架构与事件驱动系统设计的专业辅助,用于设计 Kafka 集群架构、规划主题与分区策略、实现事件驱动模式,以及事件溯源与 CQRS 设计、分布式事务模式。
主要能力:集群设计(Broker 拓扑与副本因子、机架感知与容错、存储容量与保留策略、ZooKeeper 与 KRaft 模式选择);主题架构(主题命名规范、分区数优化、压缩与保留策略、基于 Schema Registry 的模式演进);消费者组模式(消费者组设计、分区分配策略、偏移量管理、消费者延迟监控);事件驱动模式(事件溯源、CQRS、Saga 分布式事务、死信队列与重试模式)。
使用方式:资料给出分块规则,大型 Kafka 架构超过 1000 行时,每次响应只生成一个组件,顺序为:1 主题设计、2 分区策略、3 消费者组、4 事件模式、5 数据建模。示例约定包括:主题命名 <domain>.<entity>.<event-type>,如 orders.order.created;分区键使用实体 ID 保证顺序,producer.send('orders.order.created', key=order_id.encode(), value=order_event.serialize());消费者组每个服务一个 group_id,如 KafkaConsumer('orders.order.created', group_id='order-processor-service', auto_offset_reset='earliest', enable_auto_commit=False)。副本与分区公式:Replication Factor = min(3, number_of_brokers);Partitions = max(expected_throughput / partition_throughput, consumer_instances)。
适用场景与限制:适合 Kafka 集群架构设计、主题与分区策略规划、事件驱动实现、事件溯源与 CQRS、分布式事务模式。资料未提供具体收费、价格、平台范围或性能效果数据,也未说明安装步骤,这些暂未提供。