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

Kafka3.0.0版本——消费者（消费者总体工作流程图解）

news 2026/2/8 10:28:33

一、消费者总体工作流程图解

角色划分：生产者、zookeeper、kafka集群、消费者、消费者组。如下图所示:
生产者发送消息给leader，followerr主动从leader同步数据，一个消费者可以消费某一个分区数据或者一个消费者可以消费多个分区数据。如下图所示:
每个分区的数据只能由消费者组中一个消费者消费。如下图所示:
每个消费者的offset由消费者提交到系统主题保存。如下图所示:

Kafka3.0.0版本——消费者（消费者总体工作流程图解）

一、消费者总体工作流程图解角色划分：生产者、zookeeper、kafka集群、消费者、消费者组。如下图所示: 生产者发送消息给leader，followerr主动从leader同步数据，一个消费者可以消费某一个分区数据或者一个消费者可以消费多个分区数据。如下图…...

编程日记 2023/9/8 19:16:51

MacOS 为指定应用添加指定权限（浏览器无法使用摄像头、麦克风终极解决方案）

起因：需要浏览器在线做一些测评，但我的 Chrome 没有摄像头/麦克风权限，并且在设置中是没有手动添加按钮的。我尝试了重装软件，更新系统（上面的 13.5 就是这么来的，我本来都半年懒得更新系统了&#xff09…...

编程日记 2023/9/8 19:15:51

Mysql 流程控制

简介我们可以在存储过程和函数中实现比较复杂的业务逻辑，但是需要对应的流程控制语句来控制，就像Java中分支和循环语句一样，在MySQL中也提供了对应的语句，接下来就详细的介绍下。 1.分支结构 1.1 IF语句 IF 表达式1 THEN 操作1…...

编程日记 2023/9/8 19:14:50

Java学习笔记之----I/O(输入/输出）二

【今日】孩儿立志出乡关，学不成名誓不还。文件输入/输出流程序运行期间，大部分数据都在内存中进行操作，当程序结束或关闭时，这些数据将消失。如果需要将数据永久保存，可使用文件输入/输出流与指定的文件建立连接&a…...

编程日记 2023/9/8 19:13:49

2024字节跳动校招面试真题汇总及其解答（一）

1. 【算法题】重排链表给定一个单链表 L 的头节点 head ，单链表 L 表示为： L0 → L1 → … → Ln - 1 → Ln请将其重新排列后变为： L0 → Ln → L1 → Ln - 1 → L2 → Ln - 2 → … 不能只是单纯的改变节点内部的值，而是需要实际的进行节点交换。示例 1：输入：hea…...

编程日记 2023/9/8 19:12:47

【Nginx23】Nginx学习：响应头与Map变量操作

Nginx学习：响应头与Map变量操作响应头是非常重要的内容，浏览器或者客户端有很多东西可能都是根据响应头来进行判断操作的，比如说最典型的 Content-Type ，之前我们也演示过，直接设置一个空的 types 然后指定默认的数据…...

编程日记 2023/9/8 19:11:46

前端代理报错Error occured while trying to proxy to: localhost:端口

webpack配置进行前端代理时， 报错信息如下：(DEPTH_ZERO_SELF_SIGNED_CERT) 需设置：secure为false即可解决此报错 // webpack配置前端代理config["/test"]{target: https://xxxx.com,changeOrigin: true,secure: false // 这个配置…...

编程日记 2023/9/8 19:10:45

#include "widget.h" #include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget) {ui->setupUi(this);socket new QTcpSocket(this);//如果连接服务器成功，该客户端就会发射一个connected的信号。//我们…...

编程日记 2023/9/8 19:09:43

Slint学习文档

Slint学习文档 Slint Learn如何学习本文档学习顺序标志说明 Slint With VSCodeSlint With Rust依赖👎定义宏 Slint与Rust分离1.添加编译依赖（slint-build）2.编写slint文件3.编写build.rs4.编写main.rs 普通组件主窗体Windowexample 文本Texte…...

编程日记 2023/9/8 19:08:42

【最新！七麦下载量analysis参数】逆向分析与Python实现加密算法

文章目录 1. 写在前面2. 请求分析3. 加密分析4. 算法实现 1. 写在前面之前出过一个关于榜单analysis的分析，有兴趣的可以查看这篇文章：七麦榜单analysis加密分析最近运营团队那边有同事找到我们，说工作中偶尔需要统计分析一下某APP在一些主…...

编程日记 2023/9/8 19:07:40

蓝桥杯练习题（3的倍数）

问题描述小蓝对 3 的倍数很感兴趣。现在他手头有三个不同的数 a,b,c, 他想知道, 这三个数中是不是有两个数的和是 3 的倍数。例如, 当 a3,b4,c6 时, 可以找到 a 和 c 的和是 3 的倍数。例如, 当 a3,b4,c7 时, 没办法找到两个数的和是 3 的倍数。输入格式输入三行, 每行…...

编程日记 2023/9/8 19:06:39

安装Qe-7.2细节

编译直接编译报错，发现要使用gpu加速。检查linux的GPU: nvidia-smi lspci |grep -i nvidia module load cuda ./configure make all 安装curl mkdir build cd build …/configure --prefix/home/bin/local/curl make make install 加入路径： expor…...

编程日记 2023/9/8 19:05:38

3.运行项目

克隆项目使用安装的git克隆vue2版本的若依项目，博主使用的版本是3.8.6. git clone https://gitee.com/y_project/RuoYi-Vue.git目录结构如下图所示，其中ruoyi-ui是前端的内容，其它均为后端的内容。配置mysql数据库在数据库里新建一个…...

编程日记 2023/9/8 19:04:36

【算法题】2651. 计算列车到站时间

题目： 给你一个正整数 arrivalTime 表示列车正点到站的时间（单位：小时），另给你一个正整数 delayedTime 表示列车延误的小时数。返回列车实际到站的时间。注意，该问题中的时间采用 24 小时制。示例 1…...

编程日记 2023/9/8 19:03:34

Mybatis传递实体对象只能直接获取，不能使用对象.属性方式获取

mybatis的自动识别参数功能很强大，pojo实体类可以直接写进mapper接口里面，不需要在mapper.xml文件中添加paramType,但是加了可以提高mybatis的效率不加Param注解，取值的时候直接写属性 //这里是单参数，可以不加param&#xff01…...

编程日记 2023/9/8 19:02:33

flink 写入数据到 kafka 后，数据过一段时间自动删除

版本 flink 1.16.0kafka 2.3 流程描述： flink利用KafkaSource，读取kafka的数据，然后经过一系列的处理，通过KafkaSink，采用 EXACTLY_ONCE 的模式，将处理后的数据再写入到新的topic中。问题描述&#xff1…...

编程日记 2023/9/8 19:01:32

golong基础相关操作--一

package main//go语言以包作为管理单位，每个文件必须先声明包 //程序必须有一个main包 // 导入包，必须要要使用 // 变量声明了，必须要使用 import ("fmt" )/* * 包内部的变量 */ var aa 3var ss "kkk"var bb truevar …...

编程日记 2023/9/8 19:00:31

【深度学习】基于卷积神经网络的铁路信号灯识别方法

基于卷积神经网络的铁路信号灯识别方法摘要：1 引言2 卷积神经网络模型2.1 卷积神经网络结构2.2.1 卷积层2.2.2 池化层2.2.3 全连接层 3 卷积神经网络算法实现3.1 数据集制作3.2 卷积神经网络的训练过程3.2.1 前向传播过程 4 实验5 结语摘要： 目前中…...

编程日记 2023/9/8 18:59:30

DR IP-SoC China 2023 Day演讲预告 | 龙智Perforce专家解析芯片开发中的数字资产管理

2023年9月6日（周三），龙智即将亮相于上海举行的D&R IP-SoC China 2023 Day，呈现集成了Perforce与Atlassian产品的芯片开发解决方案，助力企业更好、更快地进行芯片开发。 D&R IP-SoC China 2023 Day 是中国首个…...

编程日记 2023/9/8 18:58:29

解决github连接不上的问题

改 hosts 我们在浏览器输入 GitHub 的网址时，会向 DNS 服务器发送一个请求，获取到 GitHub 网站所在的服务器 IP 地址，从而进行访问。就像你是一名快递员，在送快递前要先找中间人询问收件人的地址。而 DNS 就是这个告诉你目标地址…...

编程日记 2023/9/8 18:57:27

生成xcframework

打包 XCFramework 的方法 XCFramework 是苹果推出的一种多平台二进制分发格式，可以包含多个架构和平台的代码。打包 XCFramework 通常用于分发库或框架。使用 Xcode 命令行工具打包通过 xcodebuild 命令可以打包 XCFramework。确保项目已经配置好需要支持的平台…...

编程新知 2025/10/5 2:30:38

业务系统对接大模型的基础方案：架构设计与关键步骤

业务系统对接大模型：架构设计与关键步骤在当今数字化转型的浪潮中，大语言模型（LLM）已成为企业提升业务效率和创新能力的关键技术之一。将大模型集成到业务系统中，不仅可以优化用户体验，还能为业务决策提供…...

编程新知 2026/2/8 4:53:03

Spark 之入门讲解详细版（1）

1、简介 1.1 Spark简介 Spark是加州大学伯克利分校AMP实验室（Algorithms, Machines, and People Lab）开发通用内存并行计算框架。Spark在2013年6月进入Apache成为孵化项目，8个月后成为Apache顶级项目，速度之快足见过人之处&…...

编程新知 2026/2/5 4:17:31

练习（含atoi的模拟实现,自定义类型等练习）

一、结构体大小的计算及位段 （结构体大小计算及位段详解请看：自定义类型：结构体进阶-CSDN博客） 1.在32位系统环境，编译选项为4字节对齐，那么sizeof(A)和sizeof(B)是多少？ #pragma pack(4)st…...

编程新知 2026/1/30 15:16:30

uni-app学习笔记二十二---使用vite.config.js全局导入常用依赖

在前面的练习中，每个页面需要使用ref，onShow等生命周期钩子函数时都需要像下面这样导入 import {onMounted, ref} from "vue" 如果不想每个页面都导入，需要使用node.js命令npm安装unplugin-auto-import npm install unplugin-au…...

编程新知 2025/9/14 18:41:15