-
Notifications
You must be signed in to change notification settings - Fork 0
MQ 包
omeyang edited this page Sep 17, 2026
·
1 revision
消息队列封装。Kafka 与 Pulsar 两种后端，统一的生产者/消费者抽象 + DLQ + OTel 链路追踪。
| 包 | 用途 | 稳定性 | 覆盖率 |
|---|---|---|---|
| xkafka | Kafka 客户端（confluent-kafka-go，DLQ + OTel） | Stable | 88.5% |
| xpulsar | Pulsar 客户端（pulsar-client-go，DLQ + OTel） | Stable | 99.5% |
-
internal/mqcore：通用消费循环RunConsumeLoop，handler panic 不补 recover，刻意 fail-fast（见 Fail-Fast 消费循环）
| 场景 | 用 |
|---|---|
| 已有 Kafka 集群、需要兼容现有生态 | xkafka |
| 多租户、延迟队列、灵活订阅模式 | xpulsar |