1. Kafka定义

  1. 传统定义:kafka是一个分布式的基于发布/订阅模式的消息队列
  2. 发布/订阅:消息的发布者不会将消息直接发送给特定的订阅者,而是将发布的消息分为不同的类别,订阅者只接收感兴趣的消息
  3. 最新定义:kafka是一个开源的分布式事件流平台,被多家公司用于高性能、流分析、数据集成和关键任务应用

2. 传统消息队列应用场景

  1. 缓存/消峰
    有助于控制和优化数据流经系统的速度,解决生产者和消费者处理速度不一致的情况

  2. 解耦
    允许独立的扩展和修改两边的处理过程,只要确保它们遵守同样的接口约束

  3. 异步通信
    允许用户把一个消息放入队列,但并不立即处理它,然后在需要的时候去处理它

3. 消息队列的两种模式

  1. 点对点模式
    消费者主动拉取数据,消息收到后清除消息

  2. 发布/订阅模式
    (1)可以有多个topic主题
    (2)消费者消费数据后,不删除数据
    (3)每个消费者相互独立,都可以消费到数据

4. kafka名词说明

  1. producer: 消息生产者
  2. consumer: 消息消费者
  3. consumer group: 消费者组,由多个consumer组成。消费者组内每个消费者负责消费不同分区的数据,一个分区只能由一个组内的一个消费者消费;但消费者组中的一个消费者可以消费多个分区;消费者组之间互不影响。
  4. Broker: 一台kafka服务器就是一个broker,一个集群由多个broker组成。
  5. topic:可以理解为一个队列,生产者和消费者面向的都是同一个topic
  6. partition(分区): 为实现扩展性,一个非常大的topic可以分布到多个broker(服务器)上,一个topic可以分为多个分区(partition),每个分区是一个有序的队列
  7. replica(副本):一个topic的每个分区都有若干个副本,即一个leader和若干个follower
  8. leader:每个分区多个副本的"主",生产者发送数据和消费者消费数据的对象都是leader
  9. follower:每个分区多个副本的"从",实时从leader中同步数据。保持和leader数据的同步。leader发生故障时,某个follower会成为新的leader

Kafka(一):概述相关推荐

  1. Kafka(1)-概述

    一. 内部原理 1. 点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除) 点对点模型通常是一个基于拉取或者轮询的消息传送模型,这种模型从队列中请求信息,而不是将消息推送到客户端.这个模型的特 ...

  2. Kafka知识点概述

    kafka架构 Kafka是如何实现消息有序的?有哪些分区算法? (一)Kafka是如何让实现消息有序的 生产者:通过分区的leader副本负责数据以先进先出的顺序写入,来保证消息顺序行.消费者:同一 ...

  3. Kafka之概述(一)

    1.1 Kafka定义 Kafka是一个分布式的基于发布/ 订阅模式的消息队列,主要应用于大数据实时处理领域. 1.2 消息队列 1.3 Kafka架构

  4. Hadoop集群高可用及zookeeper+kafka组件搭建

    目录 一.Hadoop集群高可用 1.Zookeeper概述 1)Zookeeper基本概述 3)Zab协议 3)observer 4)zookeeper集群图例 2.zookeeper集群搭建 3. ...

  5. Kafka安装和基本指令

    文章目录 消息队列概述 分类 消息系统的适用场景 消息队列对比 RabbitMQ Redis ZeroMQ ActiveMQ Kafka介绍 概述 使用场景 Messaging Website act ...

  6. kafka jar包_和同事交流不会kafka怎么行,API奉上,不是大神也能编

    对于kafka真的是又爱又恨,作为架构和大数据两个方面的通用者, 在这个数据量称雄的时代,越来越起到至关重要的作用,在和同事进行交流的时候,kafka在开发的过程中如何使用能起到最大的效果成为话题之一 ...

  7. Kafka(生产者)

    Kafka 1.概述 1.1 消息队列 1.1.1 传统消息队列的应用场景 1.1.2 消息队列的两种模式 1.2 kafka基础结构 2.kafka的快速入门 2.1 集群部署 2.1.1 安装ja ...

  8. Confluent之Kafka Connector初体验

    概述 背景 Apache Kafka 是最大.最成功的开源项目之一,可以说是无人不知无人不晓,在前面的文章<Apache Kafka分布式流处理平台及大厂面试宝典>我们也充分认识了Kafk ...

  9. Cris 玩转大数据系列之消息队列神器 Kafka

    Cris 玩转大数据系列之消息队列神器 Kafka Author:Cris 文章目录 Cris 玩转大数据系列之消息队列神器 Kafka Author:Cris 1. Kafka 概述 1.1 消息队 ...

  10. Kafka学习记录(三)——Broker

    Kafka学习记录(三)--Broker 目录 Kafka学习记录(三)--Broker 对应课程 Zookeeper存储的Kafka信息 Broker总体工作流程 Broker的服役和退役 Kafk ...

最新文章

  1. SpringMVC 学习系列 (3) 之 URL请求到Action的映射规则
  2. 2017中国互联网消费生态大数据报告
  3. 曹国伟:看准微博做大布局 哪怕革自己的命
  4. flask sqlalchemy 单表查询
  5. 18号是什么php,19年1月18号CSS浮动float
  6. ArcGIS——图形转要素(标注转注记后发布服务问题)
  7. centos安装python3_CentOS安装Python3-阿里云开发者社区
  8. 根据ip查询所在国家地区(国内外ip均适用)
  9. 支持移动触摸的jQuery图片Lightbox插件 1
  10. vc2012 异常捕获并处理
  11. ae效果英文版翻译对照表_AE特效中英名字对照表
  12. VUE3-Cesium(entity、primitive总结及材质的修改)
  13. 线性代数 【23】 概念的深入01 - Points坐标点和Vectors向量
  14. Counter对numpy数组进行统计
  15. springboot 使用 Spring Boot WebSocket 创建聊天室 2-11
  16. 阿里云服务器部署StreamX
  17. [R语言]1. R语言中R包下载存储位置和安装位置
  18. return的用法是什么?
  19. 华为荣耀8电信卡显示无服务器,华为荣耀手机实现双电信卡双待双通,5步告诉你真相...
  20. vscode同时编辑多行,插入递增数字

热门文章

  1. 如何选择低价高防服务器?
  2. 全球及中国生物识别技术产业应用趋势及投资风险分析报告2021-2027年
  3. python词频统计之红楼梦_用 Python 分析《红楼梦》,后四十回是曹雪芹所写
  4. 在 C# 中下载图片
  5. 【curl: (52) Empty reply from server】
  6. SAP HANA首次在农夫山泉成功上线
  7. Fiddler的详细介绍
  8. java regux_使用Unix命令在Java中打印Mac的序列号
  9. [gazebo_gui-2] process has died [pid 4588, exit code 134, cmd /opt/ros/kinetic/lib/gazebo_ros/gzc
  10. 从因果关系来看小样本学习