中文（UKafka 消息队列）
UKafka 提供托管式 Kafka 消息队列服务，用于构建高吞吐、可扩展的事件流与异步解耦架构，适合日志/埋点/数据管道/实时处理等场景。
适用场景
- 业务解耦：订单创建后异步触发库存、积分、通知
- 日志/埋点：应用日志集中采集，再进入检索/分析系统
- 数据管道：CDC/ETL，实时写入数仓或搜索引擎
核心概念（快速理解）
- Topic：消息主题（如
order-events） - Partition：分区决定并行度与顺序性（同分区内有序）
- Consumer Group：同组消费者共同分担一个 Topic 的消费
举例：订单事件驱动架构
当订单创建成功后，应用写入一条事件到 Topic：
- Topic：
order-events - Message：
{"type":"ORDER_CREATED","orderId":12345,"ts":1700000000}
消费者示例：
- 库存服务（group:
stock-svc）订阅后扣减库存 - 通知服务（group:
notify-svc）订阅后发送短信/邮件
最佳实践
- 为关键消息设计重试/死信策略（可配合 USNS 或业务侧实现）
- 消息体建议包含唯一 ID，便于幂等处理
- 监控延迟与积压（Consumer Lag），及时扩容
English (UKafka)
UKafka is a managed Kafka service for high-throughput event streaming and asynchronous decoupling, commonly used for logs, tracking events, data pipelines, and real-time processing.
Use cases
- Decoupling: order creation triggers async inventory/points/notifications
- Log/event ingestion for search and analytics
- Data pipelines and real-time ETL/CDC
Key concepts
- Topic (e.g.,
order-events) - Partitions define parallelism and ordering (ordered within a partition)
- Consumer group shares consumption of a topic
Example: Event-driven orders
- Topic:
order-events - Message:
{"type":"ORDER_CREATED","orderId":12345,"ts":1700000000} - Consumers: inventory service, notification service (separate consumer groups)
