时间仓促，待更新。有兴趣朋友也可以进一步关注公众号“架构之道与术”， 获取最新文章。或扫描如下二维码：

-Kafka关键概念介绍-消息队列的各种策略与语义作为一个消息队列，Kafka在业界已经相当有名。相对传统的RabbitMq/ActiveMq，Kafka天生就是分布式的，支持数据的分片、复制以及集群的方便扩展。与此同时，Kafka是高可靠的、持久化的消息队列，并且这种可靠性没有以牺牲性能为前提。同时，在允许丢消息的业务场景下，Kafka可以以非ACK、异步的方式来运行，从而最大程度的提高性能。

单线程的consumer在前面我们讲过，KafkaProducer是线程安全的，同时其内部还有一个Sender，开了一个后台线程，不断从队列中取消息进行发送。而consumer，是一个纯粹的单线程程序，后面所讲的所有机制，包括coordinator，rebalance, heartbeat等，都是在这个单线程的poll函数里面完成的。也因此，在consumer的代码内部，没有锁的出现。...

从这一篇开始，我们将进入Consumer的分析。同Producer一样， Consumer也分旧的scala版和新的Java版，在此我们只分析新的Java版。有兴趣朋友可以关注公众号“架构之道与术”， 获取最新文章。或扫描如下二维码：在分析之前，我们先看一下， Consumer的基本用法：Properties props = new Properties();...