内容推荐 本书详细介绍了Kafka与Pulsar的使用方式,并深入分析了它们的实现机制。通过阅读本书,读者可以快速入门使用Kafka与Pulsar,并深入理解它们的实现原理。 本书通过大量实践示例介绍了Kafka与Pulsar的使用方式,包括管理脚本与客户端(生产者、消费者)的使用方式、关键的配置项、ACK提交方式等基础应用,以及安全机制、跨地域复制机制、连接器/流计算引擎、常用监控管理平台等高级应用。这些内容可以帮助读者深入掌握Kafka与Pulsar的使用方式,并完成日常管理工作。另外,本书深入分析了Kafka与Pulsar的实现原理,包括客户端(生产者、消费者)的设计与实现、Broker网络模型、主题(分区)分配与负载均衡机制,以及磁盘存储与性能优化方案、数据同步机制、扩容与故障转移机制。最后,本书介绍了Kafka与Pulsar的事务机制,并深入分析了Kafka事务的实现及Kafka最新的分布式协作组件KRaft模块。这部分内容可以帮助读者轻松理解Kafka与Pulsar的架构设计与实现原理。 作者简介 梁国斌,后端高级开发,源码爱好者,对Netty、Spring、Redis、Kafka等中间件有深入研究,目前维护一个技术公众号,欢迎关注交流。 目录 第1部分 基础应用 第1章 Kafka与Pulsar概述 1.1 简介 1.2 特性 1.3 概念 1.3.1 Kafka基础概念 1.3.2 Pulsar基础概念 1.4 本章总结 第2章 Kafka的部署与调试 2.1 安装Kafka集群 2.1.1 部署ZooKeeper集群 2.1.2 部署Kafka集群 2.2 调试Kafka 2.3 本章总结 第3章 Kafka的应用 3.1 脚本 3.1.1 主题管理 3.1.2 生产者与消费者 3.1.3 动态配置 3.2 客户端 3.2.1 生产者 3.2.2 消费者 3.3 消息序列化 3.4 配额 3.5 本章总结 第4章 Pulsar的部署与调试 4.1 本地部署 4.2 集群部署 4.2.1 ZooKeeper集群部署 4.2.2 初始化集群元数据 4.2.3 部署BookKeeper集群 4.2.4 部署Pulsar Broker 4.3 调试Pulsar 4.3.1 调试Pulsar Broker源码 4.3.2 调试BookKeeper 4.4 本章总结 第5章 Pulsar的应用 5.1 租户 5.2 命名空间 5.2.1 消息保留和过期 5.2.2 持久化策略 5.2.3 消息投递速率 5.3 主题 5.3.1 创建主题 5.3.2 发送、消费消息 5.3.3 管理主题 5.4 客户端 5.4.1 生产者 5.4.2 消费者 …… 第2部分 客户端与Broker计算层 第6章 Kafka和Pulsar的架构 第7章 Kafka的主题 第8章 Kafka的生产者与消息发布 第9章 Kafka的消费者与消息订阅 第10章 Pulsar的主题 第11章 Pulsar的生产者与消息发布 第12章 Pulsar的消费者与消息订阅 第3部分 分布式数据存储 第13章 Kafka存储机制与读写流程 第14章 Kafka主从同步 第15章 Kafka分布式协同 第16章 BookKeeper客户端 第17章 BookKeeper服务端 第4部分 事务与KRaft模块 第18章 Kafka与Pulsar事务概述 第19章 Kafka事务的设计与实现 第20章 KRaft模块概述 第21章 KRaft模块的设计与实现原理 第5部分 高级应用 第22章 安全 第23章 跨地域复制与分层存储 第24章 监控与管理 第25章 连接器 第26章 流计算引擎 |