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

kafka学习笔记07

 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.lryc.cn/news/377272.html

相关文章:

  • MQTTfx连接阿里云(详细版)
  • Vue3使用provide和inject实现孙组件给爷组件传递数据
  • 昇思25天学习打卡营第1天|基本介绍及快速入门
  • C#.Net筑基-类型系统②常见类型
  • 【人机交互 复习】第5章 交互式系统的需求
  • 知识的补充
  • 微信小程序请求服务器报ERR_CONNECTION_RESET
  • SpringMVC:拦截Mybatis的mapper
  • MySQL查询性能优化解决方案
  • 系统安全(补充)
  • 腾讯云[HiFlow】| 自动化 -------HiFlow:还在复制粘贴?
  • 音视频入门基础:H.264专题(3)——EBSP, RBSP和SODB
  • 误删群晖NAS数据有什么找回的方法?
  • 【CRASH】freelist异常导致的异常地址访问
  • 【QT】C++ || 左值引用、右值引用、移动语义、完美转发
  • 【深度学习驱动流体力学】计算流体力学算例剖析与实现
  • Midjourney角色一致性如何控制两个人物
  • Python基础-引用参数、斐波那契数列、无极分类
  • 【MySQL统计函数count详解】
  • 大数据的发展,带动电子商务产业链,促进了社会的进步【电商数据采集API接口推动电商项目的源动力】
  • Python类中变量定义详解
  • c++ extern 关键字详解
  • 计算机网络:运输层 - TCP 流量控制 拥塞控制
  • Python学习打卡:day10
  • 新书速览|Ubuntu Linux运维从零开始学
  • [Qt的学习日常]--窗口
  • Vue发送http请求
  • 学习使用js和jquery修改css路径,实现html页面主题切换功能
  • (转)请介绍一下Redis的数据淘汰策略
  • APP自动化测试-Appium常见操作之详讲