Kafka

分布式、基于发布订阅模式 的存储队列

使用场景

大数据下的负载均衡、缓冲

发布、订阅模式:上游数据统一推送,下游按需拉取数据

kafka最新定义:开源的分布式事件流平台(event streaming Platform),用于高性能数据管道、流分析、数据集成和关键任务应用

消息队列

常用消息队列:kafka、ActiveMQ、RabbitMQ、RocketMQ等

在大数据场景主要采用Kafka作为消息队列

传统消息队列的应用场景:缓存/消峰解耦异步通信

缓存/消峰:

解耦:

异步处理:

消息队列的两种模式

点对点

订阅/发布

Kafka的基础架构

Producer(生产者)

Consumer(消费者)

Topic(主题)

  1. 为方便拓展,并提高吞吐量,一个topic分为多个partition

如图:TopicA分为三个partition,放在三台服务器上broker0、broker1、broker2

  1. 配合分区的设计,提出消费者组的概念,组内每个消费者并行消费

  1. 为提高可用性,为每个partition增加若干副本,类似NameNode HA

kafka的副本分为leader和follower,正常情况下消费者只消费leader,如果leader挂掉,follower有条件成为leader,被消费者消费

  1. Zookeeper 记录Kafka的信息,2.8.0版本之后可以配置不采用ZK

zookeeper记录的信息包括:

  1. 节点状态:/brokers/ids/[0,1,2] 表示有0,1,2三台服务器在使用
  2. leader信息:/brokers/topics/first/partitions/0/state “leader”:0,”isr”:[0,2] 表示partition0的leader是broker0上的副本,在broker0、和broker2上均有副本

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Hc5HeGUY-1660635771486)(…/AppData/Roaming/Typora/typora-user-images/image-20220816151354117.png)]

【Kafka】kafka架构相关推荐

  1. Kafka技术架构那些事儿

    在这篇文章中,我们将一起学习Apache Kafka的架构,ZooKeeper扮演的角色等等. 目标 在这个文章中,我们将学习Kafka基础知识.Kafka交付语义和配置,以实现不同的语义.激发Kaf ...

  2. Kafka监控架构设计

    欢迎支持笔者新作:<深入理解Kafka:核心设计与实践原理>和<RabbitMQ实战指南>,同时欢迎关注笔者的微信公众号:朱小厮的博客. 欢迎跳转到本文的原文链接:https: ...

  3. Kafka设计解析(六)- Kafka高性能架构之道

    原创文章,转载请务必将下面这段话置于文章开头处. 本文转发自技术世界,原文链接 http://www.jasongj.com/kafka/high_throughput/ 摘要 上一篇文章<Ka ...

  4. Kafka 设计架构原理详细解析(超详细图解)

    什么是Kafka? Apache Kafka是一个开放源代码的分布式事件流平台,成千上万的公司使用它来实现高性 能数据管道,流分析,数据集成和关键任务等相关的应用程序. Kafka的应用场景 构造实时 ...

  5. Kafka的架构设计

    本文来说下有关Kafka的架构设计.把握住了这个关键点,我相信你将能更好地理解 Kafka 的架构设计,进而顺藤摸瓜地掌握 Kafka 的核心技术方案. 文章目录 Kafka的技术难点究竟在哪 Kaf ...

  6. kafka 同步提交 异步_详解Kafka设计架构核心——Kafka副本机制详解

    所谓的副本机制(Replication),也可以称之为备份机制,通常是指分布式系统在多台网络互联的机器上保存有相同的数据拷贝.副本机制有什么好处呢? 1. 提供数据冗余.即使系统部分组件失效,系统依然 ...

  7. [Kafka] Kafka基本架构

    [Kafka] Kafka基本架构 [Kafka] Kafka基本架构 [Kafka] Kafka基本架构 生产者Producer :生产信息: 消费者Consumer :订阅主题.消费信息: 代理B ...

  8. Kafka整体架构图解

    1.概述 Apache Kafka最早是由LinkedIn开源出来的分布式消息系统,现在是Apache旗下的一个子项目,并且已经成为开源领域应用最广泛的消息系统之一.Kafka社区非常活跃,从0.9版 ...

  9. Kafka体系架构详细分解

    点击上方蓝色字体,选择"设为星标" 回复"资源"获取更多资源 作者:luozhiyun 地址:http://suo.im/5uYoJ0 大数据技术与架构 点击右 ...

  10. 消息队列 Kafka的架构原理 (小白必看)

    最终大家会掌握 Kafka 中最重要的概念,分别是 Broker.Producer.Consumer.Consumer Group.Topic.Partition.Replica.Leader.Fol ...

最新文章

  1. 服务器文件储存,文件储存服务器
  2. go数组去除重复_让我们一起啃算法----删除排序链表中的重复元素
  3. Swift vs. Objective-C:未来看好Swift的十个理由
  4. 三星应用程序照相机(在com.sec.android.app),三星智能相机软件下载-三星智能相机app下载V1.4.0官方版-西西软件下载...
  5. 均衡教派服务器维护,LOL十大最坑大区盘点 LOL最坑服务器 均衡教派坐实榜首
  6. ubuntu下修改网卡名称
  7. Nginx 安装 启动 停止 重启
  8. php 识别图片指定区域,简单实现图片局部识别的方法
  9. 传统企业数字化营销转型必经之路
  10. 使用postman发送post请求,header设置问题
  11. 【数学】弧长的积分公式,也即求曲线方程曲线的长度,求圆的周长公式
  12. java poi 替换word,POI替换Word中的mark标记(指定字符串)
  13. java定义语法解析器,java开发工具intellij idea使用教程:定义语法和解析器.pdf
  14. (附源码)计算机毕业设计SSM基于的校园卡管理系统
  15. java 队列 抢购_使用Redis实现抢购的一种思路(list队列实现)
  16. python django 动态网页_Django创建动态网页的基础知识
  17. 神都夜行录怎么在电脑上玩 神都夜行录安卓模拟器教程
  18. 硬件/操作系统/网络(十二):网络基本概念的知识扫盲
  19. CDR插件开发之CPG插件002 - CPG插件开发环境准备和搭建
  20. 百度地图 添加行政区域

热门文章

  1. 基于SpringBoot的毕业论文管理系统的设计与实现(开题报告)
  2. kafka连接mysql数据库,Kafka-connect-jdbc-source连接mysql数据库实战
  3. 编写mysql存储过程
  4. 60w风扇用多大电容_家用电风扇电容大小一般是多少
  5. java画图板之平面山水画(二)
  6. canvas画七巧板
  7. ead开局 华三inode_03 EAD用户接入-受控软件管理-新华三集团-H3C
  8. quartz - 宕机后的设置
  9. VLC Plugin JS 方法
  10. python打包exe报错编码问题_python打包成exe,但执行exe报错,求解。