KafkaConsumer的概念 消费者&消费者群组 消费者读取消息。在其他基于发布与订阅的消息系统中，消费者可能被称为订阅者或读者。 消费者订阅一个或多个主题，并按照消息生成的顺序读取它们。消费者通过检查消息的偏移量来区分已经读取过的消息。 偏移量是一种元数据，它是一个不断递增的整数值，在创建消息时，Kafka会把偏移量添加到消息里。在给定的分区里，每个消息的偏移量都是唯一的。消费者把每个分区最后读取的消息的偏移量保存在Zookeeper或Kafka上，如果消费者关闭或重启，它的读取状态不会丢失。 消费者群组 消费者是消费者群组的一部分。一个群组里的消费者订阅的是同一个主题，每...