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

KAFKA搭建教程

KAFKA搭建教程

 

期待您的关注

KAFKA学习笔记 帮助更多人

 

目录

KAFKA搭建教程

1.下载Kafka并解压

2.添加环境变量

3.修改 server.properties 文件

4.将kafka复制到其它节点

5.修改node1、node2节点的broker.id 

6.将master的环境变量同步到node1、 node2

7.启动zookeeper

8.启动Kafka


 

 

1.下载Kafka并解压

 

下载地址:大数据相关文件快速下载入口 (qq.com)

 

c6b805b82d394460a992747c6e08b08e.png

 

2.添加环境变量

 

vim /etc/profileexport KAFKA_HOME=/usr/local/soft/kafka_2.11-2.0.0
export path=$PATH:$KAFKA_HOME/binsource /etc/profile

 

bcf1f0fd6f744d4399487ada53696a6b.png

 

3.修改 server.properties 文件

 

cd /usr/local/soft/kafka_2.11-2.0.0/configvim server.propertiesbroker.id=0 每一个节点broker.id 要不一样log.dirs=/usr/local/soft/kafka_2.11-2.0.0/datazookeeper.connect=master:2181,node1:2181,node2:2181 消息(数据)存放的位置

 

8634e825452c40ec9ba215e0ef41ccb6.png

 

4.将kafka复制到其它节点

 

cd /usr/local/softscp -r kafka_2.11-2.0.0 node1:`pwd`
scp -r kafka_2.11-2.0.0 node2:`pwd`

 

5.修改node1、node2节点的broker.id 

 

(1) 切换node1节点cd /usr/local/soft/kafka_2.11-2.0.0/config/vim server.properties修改
broker.id=1     ( master=0   node1=1  node2=2 )(2) 切换node2节点cd /usr/local/soft/kafka_2.11-2.0.0/config/vim server.properties修改
broker.id=2     ( master=0   node1=1  node2=2 )

 

6.将master的环境变量同步到node1、 node2

 

scp -r /etc/profile node1:/etc/scp -r /etc/profile node2:/etc/source /etc/profile
source /etc/profile

 

c9651ac395e84a2cb8df5283d717aecb.png

 

============= Kafka 搭建完毕 ================

 

=============== 启动 Kafka ==================

 

7.启动zookeeper

 

1) 启动zookeeper  -- 需要在master、 node1、 node2 任意位置启动zkServer.sh start2) 查看ZK状态zkServer.sh status

 

969d24bbb1e74bce8be79e83f3afc8f2.png

 

8.启动Kafka

 

kafka-server-start.sh -daemon /usr/local/soft/kafka_2.11-2.0.0/config/server.properties

 

dacabc46010646c0b7f1406743b32def.png

 

jps查看进程

 

e343f937bfdc4aafb44f1179624ac1c0.png

 

 

 

http://www.lryc.cn/news/404307.html

相关文章:

  • Linux网络——套接字与UdpServer
  • SpringBoot源码深度解析
  • 【Qt】常用控件
  • electron 主进程和渲染进程通信
  • 【ARM】MDK-解决CMSIS_DAP.DLL missing报错
  • CSS 的环境变量函数env()
  • 数学建模--国赛备赛---TOPSIS算法
  • 均值滤波算法及实现
  • 【Apache Doris】周FAQ集锦:第 16 期
  • 单例模式_Golang
  • 代码随想录 day 18 二叉树
  • 降雨量预测 | Matlab基于ARIMA-RBF降雨量预测
  • 包含示例和模板的流程文档指南
  • 51单片机嵌入式开发:15、STC89C52RC操作蜂鸣器实现一个music音乐播放器的音乐盒
  • B树(B-Tree)数据结构
  • 【BUG】已解决:ModuleNotFoundError: No module named ‘torch‘
  • 数据结构——队列(链式结构)
  • 解决GoLand添加GOROOT提示The selected directory is not a valid home for Go Sdk的问题
  • 51单片机(STC8H8K64U/STC8051U34K64)_RA8889驱动TFT大屏_I2C_HW参考代码(v1.3) 硬件I2C方式
  • 【Python其他检查字符串占字节数的方法】
  • 梧桐数据库: 数据库技术中的重写子查询技术
  • PHP连接MySQL数据库
  • STM32自己从零开始实操:PCB全过程
  • error `slot` attributes are deprecated vue/no-deprecated-slot-attribute
  • Websocket自动消息回复服务端工具
  • 【软考】UML中的关联关系
  • 贪吃蛇超精讲(C语言)
  • 掌握Rust:函数、闭包与迭代器的综合运用
  • 【LeetCode】80.删除有序数组中的重复项II
  • Armpro搭建教程全开源版的教程