消息队列
Kafka延迟与重试退避策略实践
通过生产者/消费者重试与退避策略优化Kafka延迟与稳定性,提供可验证的配置与命令,保障高并发处理。
Kafka事务与Exactly-Once处理实践
在Kafka中通过事务与幂等生产者实现Exactly-Once处理,提供可验证的客户端配置与操作命令,保障端到端一致性。
Kafka Schema Registry与兼容策略实践
使用Schema Registry治理消息模式并设置兼容策略,提供可验证的API与CLI示例,保障演进稳定与下游兼容。
云消息服务选型:AWS SQS与Google Pub/Sub对比
比较两大云消息服务在吞吐、延迟与投递语义上的差异,指导跨云与规模化场景选型。
WebSocket背压与消息队列协同治理
在 WebSocket 场景中治理背压与缓冲,结合消息队列与限速策略,保障服务稳定与用户体验。
Redis Streams消费组与滞后治理实践
使用Redis Streams消费组处理消息与治理滞后与死信,提供可验证的命令与观测方法提升稳定性。
Redis Streams与消息处理:消费者组与持久化
以 Redis Streams 构建轻量消息系统,使用消费者组与持久化 offset 实现可靠处理与重平衡。
