在这一章中我们讨论了org.apache.kafka.clients包Java KafkaConsumer客户端部分。在撰写本章的时候,Apache Kafka还有两类旧的客户端是用Scala编写的Kafka核心模块kafka.consumer包的一部分。
这些消费者被称为简单消费者[SimpleConsumer](其实并不简单,这是一个通过包装Kafka API,允许你从特定的分区和偏移量消费)和高水平的消费者[High Level Consumer],也被称为zookeeper消费者连接器[ZookeeperConsumerConnector],这有点类似于当前的消费拥有消费组,也可调整分区,但它使用Zookeeper来管理消费者组,而不是像现在这样控制的偏移量提交和负载均衡。因为当前的消费者支持这两种行为,并且向开发人员提供了更多的可靠性和控制权,所以我们不讨论旧的API。如果你对它们感兴趣,请三思再参考 Apache Kafka文档了解更多。
|