首页 > 其他 > 详细

KafkaConsumer0.9(一)

时间:2016-01-13 02:13:04      阅读:211      评论:0      收藏:0      [点我收藏+]

Kafka0.9发布了新版consumer client。它与旧版本最大的区别是移除了基于zookeeper的high-level consumer和low-level SimpleConsumer,而代之于一个统一的consumer API,它集成了之前high-level consumer的group管理功能和low-level consumer的offset控制功能。

?

新的consumer实现了一套新的group管理机制,它使得consumer clients变得更简洁(真的比以前简洁很多。。。),并且获得更快的rebalancing。同时这个版本也完全解除了consumer client对zookeeper的依赖,直接访问kafka server使得consumer变得简单,并且能够使用到kafka server提供的安全(security)和配额机制(quota)。

?

这里多说一句,consumer不依赖zookeeper是对的,由于zookeeper本质上是一个cp而不是ap系统,它更适于用于服务协调而不是服务发现,因为对于后者来说,信息中可能包含错误总比没有信息要好。

?

为了让用户平滑地升级,0.8的consumer依然可以连接到0.9的kafka cluster。

KafkaConsumer0.9(一)

原文:http://kane-xie.iteye.com/blog/2270072

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!