我们都知道Kafka的吞吐量很大，但是Kafka究竟会不会丢失消息呢？又会不会重复消费消息呢？ 有很多公司因为业务要求必须保证消息不丢失、不重复的到达，比如无人机实时监控系统，当无人机闯入机场区域，我们必须立刻报警，不允许消息丢失。而无人机离开禁飞区域后我们需要将及时报警解除。如果消息重复了呢，我们是否需要复杂的逻辑来自己处理消息重复的情况呢，这种情况恐怕相当复杂而难以处理。但是如果我们能保证消息exactlyonce，那么一切都容易得多。 图无人机实时监控 下面我们来简单了解一下消息传递语义，以及kafka的消息传递机制。 首先我们要了解的是messagedeliverysem...

上次我们通过分析KafkaProducer的源码了解了生产端的主要流程KafkaProducer源码分析，今天学习下服务端的网络层主要做了什么，先看下KafkaServer的整体架构图 Kafka服务端架构图 由图可见Kafka的服务端主要包括网络层、API层、日志子系统、副本子系统这几个大模块。当client端发起请求时，网络层会收到请求，并把请求放到共享请求队列中，然后由API层的Handler线程从队列中取出请求，并执行请求。比如是KafkaProducer发过来的生产消息的请求，会把消息写到磁盘日志中，最后把响应返回给client 网络层 从上面的图中，可以看到Kafka服务端做...