介绍Kafka Kafka是一款基于发布与订阅的消息系统。 用生产者客户端API向Kafka生产消息，用消费者客户端API从Kafka读取这些消息。 Kafka使用Zookeeper保存元数据信息。 Kafka0.9版本之前，除了broker之外，消费者也会使用Zookeeper保存一些信息，比如消费者群组的信息、主题信息、消费分区的偏移量（在消费者群组里发生失效转移时会用到）。 到了0.9.0.0版本，Kafka引入了一个新的消费者接口，允许broker直接维护这些信息。 Kafka中的概念 消息&批次 Kafka的数据单元被称为消息。消息就好比数据库里的一个“数据行”或一条“记...