当前位置：首页 > news >正文

kafka--kafka的基本概念-topic和partition

news 2026/2/10 13:30:34

一、kafka的基本概念-topic和partition

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-bVkKLZJH-1692450929823)(004-kafka基本概念.assets/image-20210807224211926.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）将消息发…...

编程日记 2023/8/20 2:17:30

【LVS】3、LVS+Keepalived群集

为什么用它，为了做高可用服务功能 1.故障自动切换 2.健康检查 3.节点服务器高可用-HA Keepalived的三个模块： core：Keepalived的核心，负责主进程的启动、维护；调用全局配置文件进行加载和解析 vrrp：实…...

编程日记 2023/8/20 2:16:27

对前端PWA应用的部分理解和基础Demo

一、什么是PWA应用？ 1、PWA简介渐进式Web应用（Progressive Web App），简称PWA，是 Google 在 2015 年提出的一种使用web平台技术构建的应用程序，官方认为其核心在于Reliable（可靠的&#xf…...

编程日记 2023/8/20 2:15:25

CSGO饰品价格会一直下跌吗？市场何时止跌回升？

最后一届巴黎major终于落下帷幕，Vitality小蜜蜂2-0战胜GL成功赢下本次Major冠军，也是首次夺得Major冠军！有人欢喜有人忧啊，csgo搬砖的饰品商人们一点也高兴不起来。 4月-5月，csgo皮肤饰品已持续走低快两个月了。手里满…...

编程日记 2023/8/20 2:14:22

线程池原理

一、线程池的定义线程池，按照配置参数（核心线程数、最大线程数等）创建并管理若干线程对象，没有任务的时候，这些线程都处于等待空闲状态。如果有新的线程任务，就分配一个空闲线程执行。如果所有线程都处于…...

编程日记 2023/8/20 2:13:19

拷贝构造函数

1. 拷贝构造函数是构造函数的一个重载形式。 2. 拷贝构造函数的参数只有一个且必须是类类型对象的引用，使用传值方式编译器直接报错， 因为会引发无穷递归调用。 class Date { public:Date(int year 1900, int month 1, int day 1){_year year;_mont…...

编程日记 2023/8/20 2:12:17

单机部署 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 …...

编程日记 2023/8/20 2:11:15

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是一种同步并阻…...

编程日记 2023/8/20 2:10:13

java版本spring cloud 企业工程系统管理工程项目管理系统源码em

工程项目管理软件（工程项目管理系统）对建设工程项目管理组织建设、项目策划决策、规划设计、施工建设到竣工交付、总结评估、运维运营，全过程、全方位的对项目进行综合管理工程项目各模块及其功能点清单一、系统管理 1、数据字典&#xff…...

编程日记 2023/8/20 2:09:11

飞天使-k8s简单搭建

文章目录 k8s概念安装部署-第一版无密钥配置与hosts与关闭swap开启ipv4转发安装前启用脚本开启ip_vs安装指定版本docker 安装kubeadm kubectl kubelet,此部分为基础构建模版 k8s一主一worker节点部署k8s三个master部署,如果负载均衡keepalived 不可用，可以用单节点做…...

编程日记 2023/8/20 2:08:10

java中把一个list转tree的方法

环境我们有个需求，数据库要存一个无限级联的tree，比如菜单，目录，或者地区等数据，现有两个问题： 问如何设计表。怎么返回给前端一个无线级联的json数据。思考第一个问题在设计表的时候，…...

编程日记 2023/8/20 2:07:08

QT设置widget背景图片

首先说方法，在给widget或者frame或者其他任何类型的控件添加背景图时，在样式表中加入如下代码，指定某个控件，设置其背景。类名 # 控件名 { 填充方式：图片路径 } 例如： QWidget#Widget {border-image: url…...

编程日记 2023/8/20 2:06:05

【ROS】话题通信--从理论介绍到模型实现(C++)

1.简单介绍话题通信是ROS中使用频率最高的一种通信模式，话题通信是基于发布订阅模式的，也即:一个节点发布消息，另一个节点订阅该消息。像雷达、摄像头、GPS… 等等一些传感器数据的采集，也都是使用了话题通信，换言之…...

编程日记 2023/8/20 2:05:03

服务器数据恢复-EqualLogic存储RAID5数据恢复案例

服务器数据恢复环境： 一台DELL EqualLogic存储中有一组由16块SAS硬盘组建的RAID5阵列。存储存放虚拟机文件，采用VMFS文件系统，划分了4个lun。服务器故障&检测&分析： 存储设备上有两个硬盘指示灯显示黄色，存储…...

编程日记 2023/8/20 2:04:00

qsort函数详解

大家好，我是苏貝，本篇博客带大家了解qsort函数，如果你觉得我写的不错的话，可以给我一个赞👍吗，感谢❤️ 文章目录一. qsort函数参数详解1.数组首元素地址base2.数组的元素个数num和元素所占内存空间大小w…...

编程日记 2023/8/20 2:02:58

C#学习，委托，事件，泛型，匿名方法

目录委托声明委托实例化委托委托的多播委托的用途事件通过事件使用委托声明事件泛型泛型的特性泛型方法泛型的委托匿名方法编写匿名方法的语法委托类似于指针，委托是存有对某个方法的引用的一种引用类型变量，引用可以在运…...

编程日记 2023/8/20 2:01:56

2023最新版本~KEIL5使用C++开发STM32

先看效果开始教学因为是第一次写这个配置教程我会尽量详细些打开一个Keil工程移除本地core 添加在线core 第一次编译代码不会有报错修改main.c文件类型为C 点击魔术棒把ARM编译器修改为V6 第二次编译会报错语法不兼容我把汇编部分的这些代码做了…...

编程日记 2023/8/20 2:00:55

汽车领域专业术语

1. DMS/OMS/RMS/IMS DMS：即Driver Monitoring System，监测对象为Driver（驾驶员）。DMS三大核心： OMS：即Occupancy Monitoring System，监测对象为乘客。 RMS：后排盲区检测系统 IMS&…...

编程日记 2023/8/20 1:59:53

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/8/20 1:58:49

零基础自学：2023 年的今天，请谨慎进入网络安全行业

前言 2023 年的今天，慎重进入网安行业吧，目前来说信息安全方向的就业对于学历的容忍度比软件开发要大得多，还有很多高中被挖过来的大佬。理由很简单，目前来说，信息安全的圈子人少，985、211 院校很多都才…...

编程日记 2023/8/20 1:57:48

浏览器访问 AWS ECS 上部署的 Docker 容器（监听 80 端口）

✅ 一、ECS 服务配置 Dockerfile 确保监听 80 端口 EXPOSE 80 CMD ["nginx", "-g", "daemon off;"]或 EXPOSE 80 CMD ["python3", "-m", "http.server", "80"]任务定义（Task Definition&…...

编程新知 2026/2/8 15:03:14

MPNet：旋转机械轻量化故障诊断模型详解python代码复现

目录一、问题背景与挑战二、MPNet核心架构 2.1 多分支特征融合模块（MBFM） 2.2 残差注意力金字塔模块（RAPM） 2.2.1 空间金字塔注意力（SPA） 2.2.2 金字塔残差块（PRBlock） 2.3 分类器设计三、关键技术突破 3.1 多尺度特征融合 3.2 轻量化设计策略 3.3 抗噪声…...

编程新知 2026/2/7 5:16:28

【OSG学习笔记】Day 18: 碰撞检测与物理交互

物理引擎（Physics Engine） 物理引擎是一种通过计算机模拟物理规律（如力学、碰撞、重力、流体动力学等）的软件工具或库。它的核心目标是在虚拟环境中逼真地模拟物体的运动和交互，广泛应用于游戏开发、动画制作、虚…...

编程新知 2026/2/4 2:08:30

dedecms 织梦自定义表单留言增加ajax验证码功能

增加ajax功能模块，用户不点击提交按钮，只要输入框失去焦点，就会提前提示验证码是否正确。一，模板上增加验证码 <input name"vdcode"id"vdcode" placeholder"请输入验证码" type"text&quo…...

编程新知 2026/2/5 17:51:52

MMaDA: Multimodal Large Diffusion Language Models

CODE ： https://github.com/Gen-Verse/MMaDA Abstract 我们介绍了一种新型的多模态扩散基础模型MMaDA，它被设计用于在文本推理、多模态理解和文本到图像生成等不同领域实现卓越的性能。该方法的特点是三个关键创新:(i) MMaDA采用统一的扩散架构&#xf…...

编程新知 2026/2/3 15:24:36