TDH大数据平台培训_第07讲_分布式消息队列Kafka.pdf

分布式消息队列 K a f k a 范 颖 捷 | 2018.04 星 环 科 技 星 环 科 技 1 Kafka简介 目录 2 Kafka原理 CONTENTS 3 Kafka使用 1 chapter Kafka简介  什么是Kafka  消息队列的作用 1.1 什么是Kafka Kafka简介  概念 • 基于发布/订阅的分布式消息系统 • 由Linkedin开发，用Scala语言编写  特性 • 消息持久化：采用时间复杂度O(1)的磁盘存储结构，即使TB级以上数据也能保证常数时间的 访问速度 • 高吞吐：支持每秒百万级的消息处理 • 高容错：多分区、多副本 • 易扩展：新增机器，集群无需停机，自动感知 • 多客户端支持：Java 、PHP 、Python等 • 同时支持离线、实时数据处理 星 环 科 技 1.2 消息队列的作用 Kafka简介  异步通信  应用解耦 • 在应用处理过程中插入一个隐含的、基于数据的接口层  数据持久化 • 高可用、高容错  送达保证 • 除非客户端明确表示已处理完，否则消息会被放回队列  顺序保证 DB 日志 传感器数据 DB 日志 传感器数据 • 分区内消息顺序处理  可恢复性 Kafka  可扩展性 • 增大消息发布和处理的频率很容易 Hadoop Streaming Web Hadoop Streaming Web  峰值处理 星 环 科 技 2 chapter Kafka原理  Kafka工作机制  Kafka核心概念  Kafka存储  Kafka高可用 2.1 Kafka工作机制 Kafka原理  Producer是消息生产者，Consumer是消息消费者 （属于特定的Consumer Group ）  Broker是Kafka的一个实例， 一个Kafka集群可以启动多个Broker  Zookeeper负责Kafka集群管理 星 环 科 技 2.1 Kafka工作机制 Kafka原理  消息在Broker中按Topic （主题）进行分类，相