kafka学习笔记07

news2025/2/25 15:27:43

 Kafka高可用集群搭建节点需求规划

开放端口。

 Kafka高可用集群之zookeeper集群搭建环境准备

删除之前的kafka和zookeeper。

重新进行环境部署:

我们解压我们的zookeeper:

编辑第一个zookeeper的配置文件:

我们重复类似的操作,创建三个zookeeper节点:

记得改对应的端口号。

  • dataDir对应目录下分别创建myid文件,内容对应1、2、3

# server.服务器id=服务器IP地址:服务器直接通信端口:服务器之间选举投票端口

每一个配置文件都做如下修改。

Kafka高可用集群之zookeeper集群搭建实战

我们可以去查看日志。

我们启动其他两个节点。

可以查看到zookeeper的状态。

我们可以看到一个leader和两个follower。

我们每次kill掉一个zk节点都会在日志中看到选举的日志。

 Kafka高可用集群搭建-环境准备

我们重新解压我们的kafka:

修改配置文件:

从0改成1.

一个配置公网ip,一个配置私网Ip。

用于存放不同节点的log日志。

因为zk是集群的形式,所以我们也修改下这个配置。

我们还需要改一下我们的端口号:

我们创建其他节点:

我们就这样创建了剩下的两个kafka。

其他按照上面步骤做类似处理即可。

Kafka高可用集群之多个Kafka节点搭建实战

启动3个kafka

更改这个防止内存不够。

再启动我们就启动成功了。

我们用这种方式开启三个kafa。

我们在其中一个节点创建一个topic:

在kafka1节点运行。

开发多个端口。

我们去执行一下:

创建topic。

我们现在也可以发送消息:

Kafka的中的日志数据清理你知道多少

我们可以看到很多日志文件。

我们可以查看到它的大小。

我们去看kafka的配置文件:

定时任务日志配置。

Kafka高可用集群搭建实战-守护进程方式启动

每个节点都按照这种方式去启动。

我们现在把这三个窗口关掉:

我们发现三个进程都在启动。

执行这个方法:

我们就可以用这种方式启动。

 Kafka的高性能原理分析归纳ZeroCopy

Kafka的高性能原理分析归纳总结

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1841937.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

最新暑假带刷规划:50天吃透660+880!

现在只刷一本题集根本不够 去做做24年的考研真题卷就什么都明白了,24年的卷子就是典型的知识点多,杂,计算量大。 而现在市面上的任何一本题集,都无法做到包含所有的知识点,毕竟版面有限! 所以&#xff0…

Python+Pytest+Yaml+Allure接口自动化测试框架详解

PythonPytestYamlAllure整体框架目录(源代码请等下篇) 框架详解 common:公共方法包 –get_path.py:获取文件路径方法 –logger_util.py:输出日志方法 –parameters_until.py:传参方式方法封装 –requests_util.py:请求方式方法封…

《人工智能导论》书面作业

第 1 章:绪论 1、分别解释人工智能的三个主要学派的代表人物和主要思想,并给出每个学派的一个实际应用实例。 符号主义(Symbolists 或 逻辑主义): 代表人物:马文闵斯基(Marvin Minsky&#xf…

SEO工具,SEO优化人员必备工具

工欲善其事必先利其器,现在是一个讲究效率的时代,学会使用工具,往往能事半功倍!使用SEO工具可以帮助你更有效地进行关键词研究,创建高质量的内容,以及建立高质量的外部链接。通过这些工具,你可以…

全面赋能,永久免费!讯飞星火API能力正式免费开放

2023年5月,讯飞星火正式发布,迅速成为千万用户获取知识、学习知识的“超级助手”,成为解放生产力、释放想象力的“超级杠杆”。 2024年5月,讯飞星火API能力正式免费开放,携手生态开发者加快大模型赋能刚需场景。 领…

嵌入式开发十九:SysTick—系统定时器

在前面实验中我们使用到的延时都是通过SysTick进行延时的。 我们知道,延时有两种方式:软件延时,即CPU 循环等待产生的,这个延时是不精确的。第二种就是滴答定时器延时,本篇博客就来介绍 STM32F4 内部 SysTick 系统定时…

如何手撸一个自有知识库的RAG系统

RAG通常指的是"Retrieval-Augmented Generation",即“检索增强的生成”。这是一种结合了检索(Retrieval)和生成(Generation)的机器学习模型,通常用于自然语言处理任务,如文本生成、问…

硬件开发笔记(二十):AD21导入外部下载的元器件原理图库、封装库和3D模型

若该文为原创文章,转载请注明原文出处 本文章博客地址:https://hpzwl.blog.csdn.net/article/details/139707771 长沙红胖子Qt(长沙创微智科)博文大全:开发技术集合(包含Qt实用技术、树莓派、三维、OpenCV…

一文读懂分布式系统CAP理论与BASE理论概念

CAP理论 Cap理论又被称作布鲁尔定理(Brewers theorem),它指出对于一个分布式系统来说,不可能同时满足如下三点: 一致性(Consistency) 可用性(Availability) 分区容错性(Partition tolerance)(以实际效果而言,分区相当于对通信的时限要求。系统如果不能在时限内达…

windows 系统根据端口查找进程,杀死进程

在启动项目时,往往设置的端口被占用,这时需要杀死端口所占用的进程,然后再重启项目。 netstat -ano | findstr :8085 taskkill /F /PID 25184 杀死进程后,再执行命令 netstat -ano | findstr :8085 进行查看端口占用情况

B树(数据结构篇)

数据结构之B树 B-树(B-tree) 概念: B-树是一个非二叉树的多路平衡查找树(数据有序),是一颗所有数据都存储在树叶节点上的树,不一定存储具体的数据,也可以是指向包含数据的记录的指针或地址 对于**阶为M(子节点数量在2和M之间)*…

嵌入式数据库_2.嵌入式数据库的一般架构

嵌入式数据库的架构与应用对象紧密相关,其架构是以内存、文件和网络等三种方式为主。 1.基于内存的数据库系统 基于内存的数据库系统中比较典型的产品是每个McObject公司的eXtremeDB嵌入式数据库,2013年3月推出5.0版,它采用内存数据结构&…

Ansys Mechanical|学习方法

Ansys Mechanical是Ansys的旗舰产品之一,涉及的学科体系全面丰富,包括的力学分支主要有理论力学,振动理论,连续介质力学,固态力学,物理力学,爆炸力学及应用力学等。 在自媒体及数字经济飞速发展…

Samtec制造理念系列一 | 差异变量的概念

【摘要/前言】 制造高端电子产品是非常复杂精密的过程。制作用于演示或原型的一次性样品可能具有挑战性,但真正的挑战在于如何以盈利的方式持续生产。 这就是Samtec风险投资研发工程总监Aaron Tucker在一次关于生产高密度微小型连接器的挑战的演讲中所强调的观点。…

使用QMainWindow、QMenuBar,QToolBar文本编辑器界面布局设置

使用QMainWindow、QMenuBar,QToolBar设计一个文本编辑器的界面 菜单 菜单输入处输入 文件$F ,呈现文件(F),快捷键AltF ,打开文件菜单 添加工具栏 在窗体空白处,右键添加工具栏 Action工具 在Designer界面下方 批量定义action 拖入到menu和 toolBar中 Too…

Docker 拉取镜像失败处理 配置使用代理拉取

解决方案 1、在 /etc/systemd/system/docker.service.d/http-proxy.conf 配置文件中添加代理信息 2、重启docker服务 具体操作如下: 创建 dockerd 相关的 systemd 目录,这个目录下的配置将覆盖 dockerd 的默认配置 代码语言:javascript 复…

阿里云API文档有哪些实用功能?如何使用?

阿里云API安全性如何保障?阿里云API怎么实现自动化? 阿里云作为全球领先的云计算服务提供商,提供了广泛的API接口,以满足各类用户的需求。阿里云API文档不仅详尽,而且易于使用,AokSend将详细介绍阿里云API…

事务的实现机制

一、基础概念 事务(Transaction)是访问和更新数据库的程序执行单元;事务中可能包含一个或多个sql语句,这些语句要么都执行,要么都不执行。作为一个关系型数据库,MySQL支持事务, 事务&#xff…

关于IntelliJ IDEA 2024.1版本更新的问题

希望文章能给到你启发和灵感~ 感谢支持和关注~ 阅读指南 序幕一、基础环境说明1.1 硬件环境1.2 软件环境 二、起因三、解决四、总结 序幕 近期,IntelliJ IDEA 推出了全新2024版本,相信很多编程的爱好者或者刚接触编程的小伙伴都会…

【Linux】关于在华为云中开放了端口后仍然无法访问的问题

已在安全组中添加规则: 通过指令: netstat -nltp | head -2 && netstat -nltp | grep 8080 运行结果: 可以看到服务器确实处于监听状态了. 通过指令 telnet 公网ip port 也提示: "正在连接xxx.xx.xx.xxx...无法打开到主机的连接。 在端口 8080: 连接失败"…