标签: 消息系统
所有带有标签 "消息系统".
Kafka(三)生产者发送JSON消息+使用统一序列化器+提升吞吐量
介绍Kafka生产者发送JSON消息的实现,使用统一序列化器处理不同对象,并配置异步发送、失败记录和重试。结合邮件消息的实际大小,讨论压缩、批次大小、请求大小和等待时间对吞吐量的影响。
Kafka(二)将邮件发送从业务系统中解耦之消息系统设计
以邮件发送为例,介绍通过Kafka解耦业务系统与邮件系统的设计思路。讨论两者的职责边界、统一消息格式、发送与回调流程,以及新旧系统切换时的回退方案,为后续生产者和消费者实现提供背景。