【假一罚四】Kafka进阶赵渝强
集团直发，全新正版书籍，假一罚四，放心选购。可开发票
￥ 49.1 5.5折 ￥ 89 全新
库存2件
浙江嘉兴
认证卖家担保交易快速发货售后保障
作者赵渝强
出版社电子工业出版社
ISBN9787121426537
出版时间2022-01
装帧平装
开本16开
定价89元
货号31383728
上书时间2024-09-29
- 店主推荐
- 最新上架
![【全新正版，假一罚四】老友、爱人和大麻烦[加] 马修·派瑞9787544798501译林](https://www0.kfzimg.com/sw/kfz-cos/kfzimg/19363336/ec517fa93239f8f3_s.jpg)
商品详情
- 品相描述：全新
- 商品描述
-
作者简介
赵渝强（赵强老师），18年以上的IT行业从业经历，清华大学计算机软件专业毕业，京东大学大数据学院院长，Oracle中国有限公司高级技术顾问，华为官方认证讲师，曾在BEA、甲骨文、摩托罗拉等世界500强公司担任高级软件架构师或咨询顾问等要职，精通大数据、数据库、容器技术、中间件技术和Java技术。
目录
第1章 Kafka体系架构基础1
1.1 什么是消息系统1
1.2 消息系统的分类2
1.2.1 同步消息机制与异步消息机制3
1.2.2 队列与主题4
1.3 Kafka的体系架构5
1.3.1 消息服务器6
1.3.2 主题、分区与副本6
1.3.3 生产者7
1.3.4 消费者与消费者组8
1.4 分布式协调服务ZooKeeper9
1.4.1 ZooKeeper集群的架构9
1.4.2 ZooKeeper的节点类型10
1.4.3 ZooKeeper的观察机制13
1.4.4 ZooKeeper的分布式锁14
1.4.5 ZooKeeper在Kafka中的作用17
1.5 准备实验环境17
1.5.1 安装CentOS操作系统17
1.5.2 配置CentOS操作系统23
1.5.3 安装JDK24
第2章 部署Kafka25
2.1 部署ZooKeeper25
2.1.1 ZooKeeper的核心配置文件26
2.1.2 部署ZooKeeper的Standalone模式28
2.1.3 部署ZooKeeper的集群模式32
2.1.4 测试ZooKeeper集群35
2.2 安装部署Kafka36
2.2.1 单机单Broker的部署40
2.2.2 单机多Broker的部署42
2.2.3 多机多Broker的部署43
2.2.4 使用命令行测试Kafka44
2.3 Kafka配置参数详解45
2.4 Kafka在ZooKeeper中保存的数据46
2.5 开发客户端程序测试Kafka47
2.5.1 开发Java版本的客户端程序48
2.5.2 开发Scala版本的客户端程序50
第3章 Kafka的生产者53
3.1 Kafka生产者的执行过程53
3.2 创建Kafka生产者54
3.2.1 创建基本的消息生产者54
3.2.2 发送自定义消息对象55
3.3 生产者的消息发送模式60
3.4 生产者的高级特性61
3.4.1 生产者分区机制61
3.4.2 生产者压缩机制66
3.4.3 生产者拦截器67
3.5 生产者的参数配置71
第4章 Kafka的消费者77
4.1 Kafka消费者的消费模式77
4.1.1 消息的推送模式77
4.1.2 消息的拉取模式77
4.1.3 推送模式与拉取模式的区别78
4.1.4 消息者组78
4.2 创建Kafka消费者79
4.2.1 创建基本的消息消费者79
4.2.2 接收自定义消息对象80
4.3 消费者与消费者组82
4.3.1 消费者和消费者组与分区的关系82
4.3.2 分区的重平衡85
4.4 消费者的偏移量与提交86
4.4.1 偏移量与重平衡86
4.4.2 偏移量的提交方式87
4.5 消费者的高级特性90
4.5.1 消费者的分区策略90
4.5.2 重平衡监听器93
4.5.3 消费者的拦截器95
4.5.4 消费者的优雅退出97
4.6 消费者的参数配置98
第5章 Kafka的服务器端102
5.1 主题与分区102
5.1.1 主题和分区的关系102
5.1.2 主题的管理103
5.1.3 使用KafkaAdminClient109
5.2 消息的持久性111
5.2.1 Kafka消息持久性概述111
5.2.2 Kafka的持久化原理解析112
5.2.3 持久化的读写流程114
5.2.4 为什么要建立分段和索引115
5.3 消息的传输保障115
5.3.1 生产者的ack机制115
5.3.2 消费者与高水位线116
5.4 副本和Leader副本的选举117
5.5 Kafka配额的管理118
5.6 Kafka的日志删除与压缩120
5.6.1 日志的删除120
5.6.2 日志的压缩120
5.6.3 清理的实现细节120
5.7 Kafka与ZooKeeper123
5.7.1 ZooKeeper扮演的角色123
5.7.2 Kafka在ZooKeeper中存储的数据124
5.8 服务器端参数设置125
第6章 流处理引擎Kafka Stream130
6.1 Kafka Stream的体系架构130
6.1.1 为什么需要Kafka Stream130
6.1.2 Kafka Stream的体系架构131
6.1.3 执行Kafka Stream示例程序132
6.2 开发自己的Kafka Stream应用程序134
6.3 Kafka Stream中的数据模型139
6.3.1 KStream与KTable139
6.3.2 状态管理141
6.4 Kafka Stream中的窗口计算144
6.4.1 时间144
6.4.2 窗口145
第7章 监控Kafka151
7.1 Kafka的监控指标151
7.2 使用Kafka客户端监控工具153
7.2.1 Kafka Manager153
7.2.2 Kafka Tool157
7.2.3 KafkaOffsetMonitor162
7.2.4 JConsole163
7.3 监控ZooKeeper166
第8章 Kafka与Flink集成168
8.1 Flink的体系架构168
8.1.1 Flink中的数据集168
8.1.2 Flink的生态圈体系169
8.1.3 Flink的体系架构171
8.2 安装部署Flink Standalone模式172
8.2.1 Flink Standalone模式的部署174
8.2.2 在Standalone模式上执行Flink任务178
8.3 Flink DataSet API算子181
8.4 Flink DataStream API算子191
8.5 集成Flink与Kafka196
8.5.1 将Kafka作为Flink的Source Connector197
8.5.2 将Kafka作为Flink的Sink Connector200
第9章 Kafka与Storm集成203
9.1 离线计算与流式计算203
9.2 Apache Storm的体系架构205
9.3 部署Apache Storm207
9.3.1 部署Storm的伪分布模式209
9.3.2 部署Storm的全分布模式213
9.3.3 Storm HA模式216
9.4 执行Apache Storm任务220
9.4.1 执行WordCountTopology220
9.4.2 Storm的其他管理命令224
9.5 开发自己的Storm任务224
9.5.1 Storm Topology任务处理的数据模型224
9.5.2 开发自己的WordCountTopology任务226
9.6 集成Kafka与Storm232
9.6.1 Storm从Kafka中接收数据233
9.6.2 测试Kafka与Storm的集成236
9.6.3 Storm将数据输出到Kafka238
第10章 Kafka与Spark集成240
10.1 Spark基础240
10.1.1 Spark的特点241
10.1.2 Spark的体系架构242
10.2 安装部署Spark环境243
10.2.1 伪分布模式的单节点环境部署246
10.2.2 全分布模式的环境安装部署248
10.3 执行Spark任务249
10.3.1 使用spark-submit提交任务249
10.3.2 交互式命令行工具spark-shell251
10.4 Spark的核心编程模型256
10.4.1 什么是RDD256
10.4.2 RDD的算子257
10.4.3 开发自己的WordCount程序260
10.5 流式计算引擎Spark Streaming264
10.5.1 什么是Spark Streaming264
10.5.2 离散流265
10.5.3 开发自己的Spark Streaming程序266
10.6 集成Kafka与Spark Streaming269
10.6.1 基于Receiver的方式269
10.6.2 直接读取的方式271
第11章 Kafka与Flume集成274
11.1 Apache Flume基础274
11.1.1 Apache Flume的体系架构274
11.1.2 Apache Flume的安装和部署278
11.2 Flume的Source组件280
11.3 Flume的Channel组件282
11.4 Flume的Sink组件283
11.5 集成Kafka与Flume287
内容摘要
本书基于作者多年的教学与实践进行编写，重点介绍Kafka消息系统的核心原理与架构，内容涉及开发、运维、管理与架构。全书共11章，第1章，介绍Kafka体系架构基础，包括消息系统的基本知识、Kafka的体系架构与ZooKeeper；第2章，介绍Kafka的环境部署，以及基本的应用程序开发；第3章，介绍Kafka的生产者及其运行机制，包括生产者的创建和执行过程、生产者的消息发送模式和生产者的高级特性等；第4章，介绍Kafka的消费者及其运行机制，包括消费者的消费模式、消费者组与消费者、消费者的偏移量与提交及消费者的高级特性等；第5章，介绍Kafka服务器端的核心原理，包括主题与分区、消息的持久性与传输保障、Kafka配额与日志的管理；第6章，介绍Kafka的流处理引擎KafkaStream；第7章，介绍使用不同的工具监控Kafka，包括KafkaManager、KafkaTool、KafkaOffsetMonitor和JConsole；第8章至第11章，介绍Kafka与外部系统的集成，包括集成Flink、集成Storm、集成Spark和集成Flume。
相关推荐
— 没有更多了 —
以下为对购买帮助不大的评价