0x00 前情摘要

kafka利用率不高

系统复杂化，领域事件逐渐增多。使用应用内消息发布框架异步调用API并不是很好的选择

0x01 期望

接入kafka后发布便捷发布领域事件：key + payload
高效的序列化与反序列化机制：protobuf
kafka listener封装
如何使得kafka作为事件总线足够可靠？配置 + 防丢 + 防重

0x02 方案

根据具体的场景，区分不同的topic。例如：订单、活动、发货单、售后等
使用默认的json序列化和反序列化器。不设置key，使用默认的分区器
防丢使用kafka的机制，所有副本收到之后才返回ack；
防重两种方式：1）保证处理消息时的幂等性；2）建立去重表
关闭自动提交，在代码中完成提交

0xFF 参考

SpringBoot集成kafka全面实战_Felix-CSDN博客