(一)、消费者连接器如何创建数据流=====》消费者初始化

以0.10.2.1版本为主分析kafka源码。如有分析不当之处,还望留言指出,相互学习,谢谢!。 1、目前kafak的消费者连接器只有一种基于zookeeper的     老版本中的消费者只有两个方法:根据配置文件创建消费者连接器   创建基于java的连接器,其实还是zookeeper的 消费者连接器内部通过调用consume方法创建数据流。核心主要放在consume方法内部。 consume方
相关文章
相关标签/搜索