kafka消息系统语义

一、概述 1. 在一个分布式发布订阅消息系统中，组成系统的计算机总会由于各自的故障而不能工作。在Kafka中，一个单独的broker，可能会在生产者发送消息到一个topic的时候宕机，或者出现网络故障，从而导致生产者发送消息失败。根据生产者如何处理这样的失败，产生了不同的语义： a. 至少一次语义（At least once semantics）：如果生产者收到了Kafka broker的确认（a

>>阅读原文<<