kafka--kafka的基本概念-topic和partition
一、kafka的基本概念-topic和partition
![[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-bVkKLZJH-1692450929823)(004-kafka基本概念.assets/image-20210807224211926.png)]](https://img-blog.csdnimg.cn/47f3fbb546d64c3ba9a480e1a3209d13.png)
1、topic （主题 ）
topic是逻辑概念
-
以Topic机制来对消息进行分类的，同一类消息属于同一个Topic，你可以将每个topic看成是一个消息队列。
-
生产者（producer）将消息发送到相应的Topic，而消费者（consumer）通过从Topic拉取消息来消费
-
kafka中是要求消费者主动拉取消息消费的，它并不会主动推送消息
2、partition（分区）
每个topic可以有多个分区，这是kafka为了提高并发量而设计的一种机制：
一个topic下的多个分区可以并发接收消息，同样的也能供消费者并发拉取消息，即分区之间互不干扰，这样的话，有多少个分区就可以有多大的并发量。
所以，如果要更准确的打比方，一个分区就是一个消息队列，只不过这些消息队列同属于一种消息分类
分区是有序，主题不是有序的
分区的目的 分散磁盘的IO
可以再增加分区
相关文章：
kafka--kafka的基本概念-topic和partition
一、kafka的基本概念-topic和partition 1、topic （主题 ） topic是逻辑概念 以Topic机制来对消息进行分类的，同一类消息属于同一个Topic，你可以将每个topic看成是一个消息队列。 生产者（producer）将消息发…...
【LVS】3、LVS+Keepalived群集
为什么用它，为了做高可用 服务功能 1.故障自动切换 2.健康检查 3.节点服务器高可用-HA Keepalived的三个模块： core：Keepalived的核心，负责主进程的启动、维护；调用全局配置文件进行加载和解析 vrrp：实…...
对前端PWA应用的部分理解和基础Demo
一、什么是PWA应用？ 1、PWA简介 渐进式Web应用（Progressive Web App），简称PWA，是 Google 在 2015 年提出的一种使用web平台技术构建的应用程序，官方认为其核心在于Reliable（可靠的…...
CSGO饰品价格会一直下跌吗？市场何时止跌回升？
最后一届巴黎major终于落下帷幕，Vitality小蜜蜂2-0战胜GL成功赢下本次Major冠军，也是首次夺得Major冠军！有人欢喜有人忧啊，csgo搬砖的饰品商人们一点也高兴不起来。 4月-5月，csgo皮肤饰品已持续走低快两个月了。手里满…...
线程池原理
一、线程池的定义 线程池，按照配置参数（核心线程数、最大线程数等）创建并管理若干线程对象，没有任务的时候，这些线程都处于等待空闲状态。如果有新的线程任务，就分配一个空闲线程执行。如果所有线程都处于…...
拷贝构造函数
1. 拷贝构造函数是构造函数的一个重载形式。 2. 拷贝构造函数的参数只有一个且必须是类类型对象的引用，使用传值方式编译器直接报错， 因为会引发无穷递归调用。 class Date { public:Date(int year 1900, int month 1, int day 1){_year year;_mont…...
数据库： MySQL安装部署、主从
单机部署 mkdir -p /opt/soft/archive cd /opt/soft/archivewget -i -c https://dev.mysql.com/get/mysql80-community-release-el7-7.noarch.rpm yum install -y mysql80-community-release-el7-7.noarch.rpm yum-config-manager --enable mysql80-community yum install -y …...
Java IO流（二）IO模型(BIO|NIO|AIO)
概述 Java IO模型同步阻塞IO（BIO）、同步非阻塞IO（NIO）、异步非阻塞IO（AIO/NIO2）,Java中的BIO、NIO和AIO理解为是Java语言对操作系统的各种IO模型的封装 IO模型 BIO(Blocking I/O) 概述 BIO是一种同步并阻…...
java版本spring cloud 企业工程系统管理 工程项目管理系统源码em
工程项目管理软件（工程项目管理系统）对建设工程项目管理组织建设、项目策划决策、规划设计、施工建设到竣工交付、总结评估、运维运营，全过程、全方位的对项目进行综合管理 工程项目各模块及其功能点清单 一、系统管理 1、数据字典ÿ…...
飞天使-k8s简单搭建
文章目录 k8s概念安装部署-第一版无密钥配置与hosts与关闭swap开启ipv4转发安装前启用脚本开启ip_vs安装指定版本docker 安装kubeadm kubectl kubelet,此部分为基础构建模版 k8s一主一worker节点部署k8s三个master部署,如果负载均衡keepalived 不可用，可以用单节点做…...
java中把一个list转tree的方法
环境 我们有个需求，数据库要存一个无限级联的tree，比如菜单，目录，或者地区等数据，现有两个问题： 问如何设计表。怎么返回给前端一个无线级联的json数据。 思考 第一个问题 在设计表的时候，…...
QT设置widget背景图片
首先说方法，在给widget或者frame或者其他任何类型的控件添加背景图时，在样式表中加入如下代码，指定某个控件，设置其背景。 类名 # 控件名 { 填充方式：图片路径 } 例如： QWidget#Widget {border-image: url…...
【ROS】话题通信--从理论介绍到模型实现(C++)
1.简单介绍 话题通信是ROS中使用频率最高的一种通信模式，话题通信是基于发布订阅模式的，也即:一个节点发布消息，另一个节点订阅该消息。像雷达、摄像头、GPS… 等等一些传感器数据的采集，也都是使用了话题通信，换言之…...
服务器数据恢复-EqualLogic存储RAID5数据恢复案例
服务器数据恢复环境： 一台DELL EqualLogic存储中有一组由16块SAS硬盘组建的RAID5阵列。存储存放虚拟机文件，采用VMFS文件系统，划分了4个lun。 服务器故障&检测&分析： 存储设备上有两个硬盘指示灯显示黄色，存储…...
qsort函数详解
大家好，我是苏貝，本篇博客带大家了解qsort函数，如果你觉得我写的不错的话，可以给我一个赞👍吗，感谢❤️ 文章目录 一. qsort函数参数详解1.数组首元素地址base2.数组的元素个数num和元素所占内存空间大小w…...
C#学习，委托，事件，泛型，匿名方法
目录 委托 声明委托 实例化委托 委托的多播 委托的用途 事件 通过事件使用委托 声明事件 泛型 泛型的特性 泛型方法 泛型的委托 匿名方法 编写匿名方法的语法 委托 类似于指针，委托是存有对某个方法的引用的一种引用类型变量，引用可以在运…...
2023最新版本~KEIL5使用C++开发STM32
先看效果 开始教学 因为是第一次写这个配置教程 我会尽量详细些 打开一个Keil工程 移除本地core 添加在线core 第一次编译代码 不会有报错 修改main.c文件类型为C 点击魔术棒 把ARM编译器修改为V6 第二次编译会报错语法不兼容 我把汇编部分的这些代码做了…...
汽车领域专业术语
1. DMS/OMS/RMS/IMS DMS：即Driver Monitoring System，监测对象为Driver（驾驶员）。DMS三大核心： OMS：即Occupancy Monitoring System，监测对象为乘客。 RMS：后排盲区检测系统 IMS&…...
H3C交换机如何配置本地端口镜像并在PC上使用Wireshake抓包
环境： H3C S6520-26Q-SI version 7.1.070, Release 6326 Win 10 专业版 Wireshake Version 4.0.3 问题描述： H3C交换机如何配置本地端口镜像并在PC上使用Wireshake抓包 解决方案： 配置交换机本地端口镜像 1.进入系统视图，并创建本地镜像组1 <H3C>system-vie…...
零基础自学：2023 年的今天，请谨慎进入网络安全行业
前言 2023 年的今天，慎重进入网安行业吧，目前来说信息安全方向的就业对于学历的容忍度比软件开发要大得多，还有很多高中被挖过来的大佬。 理由很简单，目前来说，信息安全的圈子人少，985、211 院校很多都才…...
进程地址空间（比特课总结）
一、进程地址空间 1. 环境变量 1 ）⽤户级环境变量与系统级环境变量 全局属性：环境变量具有全局属性，会被⼦进程继承。例如当bash启动⼦进程时，环 境变量会⾃动传递给⼦进程。 本地变量限制：本地变量只在当前进程(ba…...
K8S认证|CKS题库+答案| 11. AppArmor
目录 11. AppArmor 免费获取并激活 CKA_v1.31_模拟系统 题目 开始操作： 1）、切换集群 2）、切换节点 3）、切换到 apparmor 的目录 4）、执行 apparmor 策略模块 5）、修改 pod 文件 6）、…...
基于当前项目通过npm包形式暴露公共组件
1.package.sjon文件配置 其中xh-flowable就是暴露出去的npm包名 2.创建tpyes文件夹，并新增内容 3.创建package文件夹...
学习STC51单片机31（芯片为STC89C52RCRC）OLED显示屏1
每日一言 生活的美好，总是藏在那些你咬牙坚持的日子里。 硬件：OLED 以后要用到OLED的时候找到这个文件 OLED的设备地址 SSD1306"SSD" 是品牌缩写，"1306" 是产品编号。 驱动 OLED 屏幕的 IIC 总线数据传输格式 示意图 …...
在Ubuntu中设置开机自动运行（sudo）指令的指南
在Ubuntu系统中，有时需要在系统启动时自动执行某些命令，特别是需要 sudo权限的指令。为了实现这一功能，可以使用多种方法，包括编写Systemd服务、配置 rc.local文件或使用 cron任务计划。本文将详细介绍这些方法，并提供…...
多种风格导航菜单 HTML 实现（附源码）
下面我将为您展示 6 种不同风格的导航菜单实现，每种都包含完整 HTML、CSS 和 JavaScript 代码。 1. 简约水平导航栏 <!DOCTYPE html> <html lang"zh-CN"> <head><meta charset"UTF-8"><meta name"viewport&qu…...
项目部署到Linux上时遇到的错误（Redis，MySQL，无法正确连接，地址占用问题）
Redis无法正确连接 在运行jar包时出现了这样的错误 查询得知问题核心在于Redis连接失败，具体原因是客户端发送了密码认证请求，但Redis服务器未设置密码 1.为Redis设置密码（匹配客户端配置） 步骤： 1）.修…...
Spring是如何解决Bean的循环依赖：三级缓存机制
1、什么是 Bean 的循环依赖 在 Spring框架中，Bean 的循环依赖是指多个 Bean 之间互相持有对方引用，形成闭环依赖关系的现象。 多个 Bean 的依赖关系构成环形链路，例如： 双向依赖：Bean A 依赖 Bean B，同时 Bean B 也依赖 Bean A（A↔B）。链条循环： Bean A → Bean…...
Linux离线（zip方式）安装docker
目录 基础信息操作系统信息docker信息 安装实例安装步骤示例 遇到的问题问题1：修改默认工作路径启动失败问题2 找不到对应组 基础信息 操作系统信息 OS版本：CentOS 7 64位 内核版本：3.10.0 相关命令： uname -rcat /etc/os-rele…...
网站指纹识别
网站指纹识别 网站的最基本组成：服务器（操作系统）、中间件（web容器）、脚本语言、数据厍 为什么要了解这些？举个例子：发现了一个文件读取漏洞，我们需要读/etc/passwd，如…...