1、整体流程

流程图

词汇

  1. topic:主题
  2. producer:生产者
  3. consumer:消费者
  4. consumer-group:消费者组
  5. offset:偏移量
  6. follower:副本

要点概述

  1. kafka是以topic进行分类的,由producer生产数据发送到topic,再被consumer进行消费,同时offset会记录每个分区的消费进度,就算中途挂掉了,下次也会从offset开始继续消费
  2. 每个topic可以有多个分区,每个分区可以配置1个或多个副本,形成leader-follower的关系,leader和follower不会在同一个节点上(这点和Elasticsearch类似)
  3. 每个分区只能被一个consumer消费,如果consumer数量比分区还多,会存在部分consumer闲置,没有数据可以消费

2、生产者

Kafka工作原理简要概述相关推荐

  1. 三极管 和 场效应管 的工作原理 简要概述

    晶体管的概念 严格意义上讲,晶体管泛指一切以半导体材料为基础的单一元件,包括各种半导体材料制成的二极管.三极管.场效应管.可控硅等,但是国内习惯上,把晶体管有时多用来指晶体三极管. 三极管,全称应为半 ...

  2. 简单分析KafKa工作原理

    架构图 Producer:Producer即生产者,消息的产生者,是消息的入口. kafka cluster: Broker:Broker是kafka实例,每个服务器上有一个或多个kafka的实例,我 ...

  3. HashMap的实现原理(简要概述)

    HashMap的实现原理(简要概述) 基于哈希算法实现的,它通过put存储,通过get取值. 当传入一个key时,HashMap会根据key.hashCode()计算出哈希值,然后根据这个哈希值将va ...

  4. kafka同一个group 消费两个topic吗_MQ: 一张图读懂kafka工作原理

    1.关于kafka Kafka是由Apache软件基金会开发的一个开源消息队列,由Scala和Java编写. 相关文章参考: MQ: 消息队列常见应用场景及主流消息队列ActiveMQ.RabbitM ...

  5. Apache kafka 工作原理介绍

    消息队列 消息队列技术是分布式应用间交换信息的一种技术.消息队列可驻留在内存或磁盘上, 队列存储消息直到它们被应用程序读走.通过消息队列,应用程序可独立地执行--它们不需要知道彼此的位置.或在继续执行 ...

  6. 转-Apache kafka 工作原理介绍

    转自: https://developer.ibm.com/zh/articles/os-cn-kafka/ 消息队列 消息队列技术是分布式应用间交换信息的一种技术.消息队列可驻留在内存或磁盘上, 队 ...

  7. Kafka工作原理-数据写入、ACK、查询、消费原理

    为什么需要消息队列 周末无聊刷着手机,某宝网APP突然蹦出来一条消息"为了回馈老客户,女朋友买一送一,活动仅限今天!".买一送一还有这种好事,那我可不能错过!忍不住立马点了去.于是 ...

  8. kafka工作原理介绍

    两张图读懂kafka应用: Kafka 中的术语 broker:中间的kafka cluster,存储消息,是由多个server组成的集群. topic:kafka给消息提供的分类方式.broker用 ...

  9. P2P下载工作原理简要解释

    朋友给了一个BT的种子,查后得知就是视频的下载链接,于是质问朋友:"为什么不给我视频,而给种子."朋友无语,仿佛对待外星生物一样看待我,于是心有不甘,赶忙查清为什?摘录如下,与大家 ...

最新文章

  1. 编译执行和解释执行的区别
  2. python 三指针解决颜色分类
  3. python程序设计题怎么写_《Python语言程序设计基础》第1章程序练习题
  4. java.exe闪退_Tomcat7.0 exe闪退问题
  5. 在windows文件系统中加右键执行程序
  6. 隐藏在SWT、Swing、AWT背后的故事
  7. php案例之后台数据显示-- mysqli面向过程版(procedure oriented programming = POP)
  8. Session过期处理
  9. 【直播礼物特效】vapxtool简介(一)(企鹅电竞)
  10. 腾讯云域名转到阿里云
  11. 研祥计算机U盘启动,研华工控机U盘启动设置
  12. linux飞行模式问题解决
  13. 后缀为 axd 与 ashx 的文件有什么区别
  14. Python 网络编程
  15. 观echat的一个例子后有感
  16. BSV 上的 zk-SNARKs
  17. 从简历被拒到收割今日头条offer经验总结
  18. Spark问题14之Spark stage retry问题
  19. 电话号码的数字组合(Java)
  20. Winds下如何使用CMD命令进入MySQL数据库

热门文章

  1. 如何正确理解商业智能(BI)?
  2. SAP快速找到定制配置
  3. 短视频进入下半场,价值创造成赛点
  4. 计算机学院开展活动,团学会 | 以梦为马,不负韶华 计算机学院开展“逐梦100”活动(一)...
  5. C语言加取址符的作用,C语言中指针和取地址符的关系
  6. linux ping结果中mdev,Linux下PING中mdev含义
  7. web服务器的文档根目录,web服务器根目录中
  8. BUUCTF(pwn)[HarekazeCTF2019]baby_rop2 泄露libc基址,rop,利用gadget
  9. php_rce-攻防世界-web-ThinkPHP版本5的相关漏洞
  10. 【python教程】对多线程中join()的详细教程