返回首页
苏宁会员
购物车 0
易付宝
手机苏宁

服务体验

店铺评分与同行业相比

用户评价:----

物流时效:----

售后服务:----

  • 服务承诺: 正品保障
  • 公司名称:
  • 所 在 地:

  • Kafka技术内幕 郑奇煌 著 专业科技 文轩网
  • 新华书店正版
    • 作者: 郑奇煌 著著
    • 出版社: 人民邮电出版社
    • 出版时间:2017-11-01 00:00:00
    送至
  • 由""直接销售和发货,并提供售后服务
  • 加入购物车 购买电子书
    服务

    看了又看

    商品预定流程:

    查看大图
    /
    ×

    苏宁商家

    商家:
    文轩网图书旗舰店
    联系:
    • 商品

    • 服务

    • 物流

    搜索店内商品

    商品分类

         https://product.suning.com/0070067633/11555288247.html

     

    商品参数
    • 作者: 郑奇煌 著著
    • 出版社:人民邮电出版社
    • 出版时间:2017-11-01 00:00:00
    • 版次:1
    • 印次:1
    • 印刷时间:2017-11-01
    • 字数:1191千字
    • 页数:703
    • 开本:16开
    • 装帧:平装
    • 国别/地区:中国
    • 版权提供:人民邮电出版社

    Kafka技术内幕

    作  者:郑奇煌 著
    定  价:119
    出 版 社:人民邮电出版社
    出版日期:2017年11月01日
    页  数:703
    装  帧:平装
    ISBN:9787115469380
    主编推荐

    内容简介

    Kafka自LinkedIn开源以来就以高性能、高吞吐量、分布式的特性著称,本书以0.10版本的源码为基础,深入分析了Kafka的设计与实现,包括生产者和消费者的消息处理流程,新旧消费者不同的设计方式,存储层的实现,协调者和控制器如何确保Kafka集群的分布式和容错特性,两种同步集群工具MirrorMaker和uReplicator,流处理的两种API以及Kafka的一些不错特性等。《Kafka技术内幕 图文详解Kafka源码设计与实现》适合Kafka开发人员阅读。

    作者简介

    郑奇煌,目前就职于杭州某互联网风控公司,主要专注于大数据和流计算。对源码研究有一定的心得体会,乐于分享。

    精彩内容

    目录
    第1章Kafka入门1
    1.1Kafka流式数据平台1
    1.2Kafka的基本概念3
    1.2.1分区模型3
    1.2.2消费模型4
    1.2.3分布式模型5
    1.3Kafka的设计与实现6
    1.3.1文件系统的持久化与数据传输效率6
    1.3.2生产者与消费者8
    1.3.3副本机制和容错处理10
    1.4快速开始11
    1.4.1单机模式12
    1.4.2分布式模式14
    1.4.3消费组示例16
    1.5环境准备18
    第2章生产者22
    2.1新生产者客户端22
    2.1.1同步和异步发送消息23
    2.1.2客户端消息发送线程29
    2.1.3客户端网络连接对象31
    2.1.4选择器处理网络请求35
    2.2旧生产者客户端43
    2.2.1事件处理器处理客户端发送的消息44
    2.2.2对消息集按照节点和分区进行整理46
    2.2.3生产者使用阻塞通道发送请求48
    2.3服务端网络连接49
    2.3.1服务端使用接收器接受客户端的连接50
    2.3.2处理器使用选择器的轮询处理网络请求53
    2.3.3请求通道的请求队列和响应队列56
    2.3.4Kafka请求处理线程58
    2.3.5服务端的请求处理入口58
    2.4小结60
    第3章消费者:高级API和低级API61
    3.1消费者启动和初始化67
    3.1.1创建并初始化消费者连接器69
    3.1.2消费者客户端的线程模型70
    3.1.3重新初始化消费者72
    3.2消费者再平衡操作73
    3.2.1分区的所有权74
    3.2.2为消费者分配分区75
    3.2.3创建分区信息对象78
    3.2.4关闭和更新拉取线程管理器80
    3.2.5分区信息对象的偏移量80
    3.3消费者拉取数据82
    3.3.1拉取线程管理器82
    3.3.2抽象拉取线程87
    3.3.3消费者拉取线程90
    3.4消费者消费消息94
    3.4.1Kafka消息流94
    3.4.2消费者迭代消费消息95
    3.5消费者提交分区偏移量97
    3.5.1提交偏移量到ZK98
    3.5.2提交偏移量到内部主题99
    3.5.3连接偏移量管理器101
    3.5.4服务端处理提交偏移量的请求103
    3.5.5缓存分区的偏移量106
    3.6消费者低级API示例108
    3.6.1消息消费主流程109
    3.6.2找出分区的主副本112
    3.6.3获取分区的读取偏移量113
    3.6.4发送拉取请求并消费消息116
    3.7小结117
    3.7.1消费者线程模型117
    3.7.2再平衡和分区分配119
    第4章新消费者121
    4.1新消费者客户端125
    4.1.1消费者的订阅状态125
    4.1.2消费者轮询的准备工作134
    4.1.3消费者轮询的流程138
    4.1.4消费者拉取消息146
    4.1.5消费者获取记录149
    4.1.6消费消息160
    4.2消费者的网络客户端轮询161
    4.2.1异步请求162
    4.2.2异步请求高级模式169
    4.2.3网络客户端轮询184
    4.3心跳任务188
    4.3.1发送心跳请求188
    4.3.2心跳状态189
    4.3.3运行心跳任务191
    4.3.4处理心跳结果的示例192
    4.3.5心跳和协调者的关系193
    4.4消费者提交偏移量195
    4.4.1自动提交任务195
    4.4.2将拉取偏移量作为提交偏移量197
    4.4.3同步提交偏移量201
    4.4.4消费者的消息处理语义202
    4.5小结206
    第5章协调者210
    5.1消费者加入消费组211
    5.1.1元数据与分区分配器212
    5.1.2消费者的加入组和同步组213
    5.1.3主消费者执行分配任务220
    5.1.4加入组的准备、完成和监听器224
    5.2协调者处理请求229
    5.2.1服务端定义发送响应结果的回调方法229
    5.2.2消费者和消费组元数据232
    5.2.3协调者处理请求前的条件检查236
    5.2.4协调者调用回调方法发送响应给客户端237
    5.3延迟的加入组操作242
    5.3.1 “准备再平衡”242
    5.3.2延迟操作和延迟缓存244
    5.3.3尝试完成延迟的加入操作246
    5.3.4消费组稳定后,原有消费者重新加入消费组250
    5.3.5消费组未稳定,原有消费者重新加入消费组251
    5.4消费组状态机254
    5.4.1再平衡操作与监听器254
    5.4.2消费组的状态转换262
    5.4.3协调者处理“加入组请求”264
    5.4.4协调者处理“同步组请求”274
    5.4.5协调者处理“离开组请求”276
    5.4.6再平衡超时与会话超时278
    5.4.7延迟的心跳282
    5.5小结290
    第6章存储层293
    6.1日志的读写293
    6.1.1分区、副本、日志、日志
    分段294
    6.1.2写入日志297
    6.1.3日志分段305
    6.1.4读取日志315
    6.1.5日志管理329
    6.1.6日志压缩336
    6.2服务端处理读写请求348
    6.2.1副本管理器351
    6.2.2分区与副本362
    6.3延迟操作373
    6.3.1延迟操作接口374
    6.3.2延迟操作与延迟缓存383
    6.3.3延迟缓存391
    6.4小结400
    第7章控制器402
    7.1Kafka控制器402
    7.1.1控制器选举403
    7.1.2控制器上下文406
    7.1.3ZK监听器408
    7.1.4分区状态机和副本状态机410
    7.1.5删除主题430
    7.1.6重新分配分区436
    7.1.7控制器的网络通道管理器445
    7.2服务端处理LeaderAndIsr请求448
    7.2.1创建分区449
    7.2.2创建主副本、备份副本451
    7.2.3消费组元数据迁移463
    7.3元数据缓存468
    7.3.1服务端的元数据缓存472
    7.3.2客户端更新元数据473
    7.4Kafka服务关闭483
    7.5小结487
    第8章基于Kafka构建数据流管道490
    8.1Kafka集群同步工具:MirrorMaker490
    8.1.1单机模拟数据同步491
    8.1.2数据同步的流程493
    8.2Uber集群同步工具:uReplicator498
    8.2.1Apache Helix介绍498
    8.2.2Helix控制器501
    8.2.3Helix工作节点504
    8.3Kafka连接器505
    8.3.1连接器的使用示例507
    8.3.2开发一个简单的连接器510
    8.3.3连接器的架构模型515
    8.3.4Herder的实现520
    8.3.5Worker的实现524
    8.3.6配置存储与状态存储530
    8.3.7连接器与任务的实现550
    8.4小结565
    第9章Kafka流处理569
    9.1低级Processor API569
    9.1.1流处理应用程序示例569
    9.1.2流处理的拓扑575
    9.1.3流处理的线程模型580
    9.1.4状态存储613
    9.2高级流式DSL636
    9.2.1DSL应用程序示例636
    9.2.2KStream和KTable638
    9.2.3连接操作665
    9.2.4窗口操作672
    9.3小结684
    第10章高级特性介绍686
    10.1客户端配额686
    10.2消息与时间戳692
    10.3事务处理699
    10.4小结703

    售后保障

    最近浏览

    猜你喜欢

    该商品在当前城市正在进行 促销

    注:参加抢购将不再享受其他优惠活动

    x
    您已成功将商品加入收藏夹

    查看我的收藏夹

    确定

    非常抱歉,您前期未参加预订活动,
    无法支付尾款哦!

    关闭

    抱歉,您暂无任性付资格

    此时为正式期SUPER会员专享抢购期,普通会员暂不可抢购