分享

Kafka权威指南 第四章第12节:旧消费者API

feilong 2017-8-11 07:47:22 发表于 连载型 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 7161


在这一章中我们讨论了org.apache.kafka.clients包Java KafkaConsumer客户端部分。在撰写本章的时候,Apache Kafka还有两类旧的客户端是用Scala编写的Kafka核心模块kafka.consumer包的一部分。

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


本帖被以下淘专辑推荐:

已有(1)人评论

跳转到指定楼层
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条