绵阳梓潼网站制作公司

从新建linux虚拟机到搭建zookeeper+kafka详细版-创新互联

目录
  • 虚拟linux系统
    • 一.安装虚拟机
    • 二.创建虚拟机
    • 三. 配置网络
    • 四. 搭建集群准备工作
  • 安装jdk
    • 1. 检查是否已安装openjdk
    • 2. 下载
    • 3. 上传安装包
    • 4. 解压
    • 5. 修改环境变量
    • 6. 检测是否配置成功
  • 搭建zookeeper集群
    • 1. 下载
    • 2. 上传
    • 3. 解压
    • 4. 配置zk1
    • 5. 启动集群
    • 6. 查看启动状态
      • Error contacting service. It is probably not running
  • 搭建kafka集群
    • 1. 下载
    • 2. 上传
    • 3. 解压
    • 4. 更改文件夹名称
    • 5. 新建logs文件夹
    • 6. 修改配置文件
    • 7. 将修改后的文件扩展到computer02和computer03
    • 8. 启动kafka
  • 使用kafka
    • 1. 创建topic

创新互联主营安康网站建设的网络公司,主营网站建设方案,重庆App定制开发,安康h5微信平台小程序开发搭建,安康网站营销推广欢迎安康等地区企业咨询虚拟linux系统 一.安装虚拟机
  1. VMware软件下载地址：https://www.vmware.com/cn/products/workstation-pro/workstation-pro-evaluation.html
    按照步骤依次点击下一步即可，只有一点需要注意，请不要将VM安装默认C盘，后续本机电脑可能会卡顿，建议安装到除C盘外的任意一盘
  2. CentOS 7 下载映像文件地址：http://mirrors.aliyun.com/centos/7/isos/x86_64/
    选择CentOS-7-x86_64-DVD-2009.iso
二.创建虚拟机
  1. 创建新的虚拟机
    在这里插入图片描述
  2. 选择典型配置（自定义有些麻烦，只是自己学习搭个系统没有必要）
    在这里插入图片描述
    2.选择映射文件
    因为我这里是先建的虚拟机，后下载的centos，所以选择了稍后安装，如果你提前下载好了，可以直接选择安装的映射文件
    在这里插入图片描述
  3. 选择创建虚拟机的操作系统
    在这里插入图片描述
  4. 自定义虚拟机名字和位置
    在这里插入图片描述
  5. 选择磁盘大小：40
    在这里插入图片描述
  6. 点击完成
    在这里插入图片描述
  7. 删除一些不用的插件，增加内存空间（声卡和打印器）
    在这里插入图片描述
  8. 添加iso映射文件
    在这里插入图片描述
  9. 启动虚拟机，等待安装完成
  10. 选择语言
    在这里插入图片描述
  11. 安装位置
    在这里插入图片描述
    在这里插入图片描述
  12. 设置密码（自定义，但root或者123456这类过于简单的密码是不可以的）
    在这里插入图片描述
三. 配置网络

由于配置网络步骤过于繁复，此篇文章不再赘述，有需要请移步另一篇文章~
虚拟机linux系统与本机网络互通

四. 搭建集群准备工作
  1. 由于kafka与zookeeper集群至少需要三台机器，所以需要搭建三台虚拟机，但无需将前几步配置三次，只需要配置一次之后复制一下就可以啦~
    注意：复制虚拟机的时候需要先将虚拟机关机再复制
    在这里插入图片描述
    点击克隆之后一直点击下一步，直到选择克隆方法“创建完整克隆”
  2. computer2和computer3从computer1复制完之后，需要分别修改一下ifcfg-ens33中的IPADDR，分别将后缀改为11,12,13，为后续操作方便
安装jdk 1. 检查是否已安装openjdk
rpm -qa|grep jdk

如果已经安装openjdk，需要先卸载，再安装jdk，卸载命令如下

yum -y remove
2. 下载

下载地址：https://www.oracle.com/java/technologies/downloads/#java8
在这里插入图片描述

3. 上传安装包

新建java目录

cd /usr/local
mkdir java

上传部分由于我是用终端软件上传，并没有用VM操作，所以没有什么参考价值，大家看自己习惯来就好啦~

4. 解压
tar -zxvf jdk-8u351-linux-i586.tar.gz
5. 修改环境变量
sudo vi /etc/profile

在文件下面增加以下内容，其中JAVA_HOME的路径需要替换成自己的路径

export JAVA_HOME=/usr/local/java/jdk1.8.0_351
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin

修改之后需要执行以下命令让配置生效

source /etc/profile
6. 检测是否配置成功
java -version

如果失败，出现报错：
-bash: bin/java: /lib/ld-linux.so.2: bad ELF interpreter: 没有那个文件或目录
则可以运行以下命令，问题就可以消除

sudo yum install glibc.i686
搭建zookeeper集群 1. 下载

下载地址：https://archive.apache.org/dist/zookeeper/zookeeper-3.5.5/
在这里插入图片描述
注意：一定要注意后缀，千万不要下载错了，处处是坑！！！

2. 上传

新建zookeeper目录

cd /usr/local
mkdir zookeeper

上传过程同上节

3. 解压
tar -zxvf apache-zookeeper-3.5.5-bin.tar.gz
4. 配置zk1

step1：更改文件夹名称（更好的区分三个服务器，不改也行，只是看着不舒服）

mv apache-zookeeper-3.5.5-bin zk1

step2：新建data和logs，用于存放数据和日志

cd /usr/local/zookeeper/zk1
mkdir data logs

step3：更改zoo_sample.cfg文件名称

cd /usr/local/zookeeper/zk1/conf
mv zoo_sample.cfg zoo.cfg

step4：修改zoo.cfg文件

vi zoo.cfg

修改以下内容：

①
dataDir=/usr/local/zookeeper/zk1/data
dataLogDir=/usr/local/zookeeper/zk1/logs	#如果这一行没有就在dataDir下面新增
②
clientPort=2181	#这是客户端的请求端口号，需要记住

在文件下面添加以下内容

server.1=192.168.227.11:2881:3881
server.2=192.168.227.12:2882:3882
server.3=192.168.227.13:2883:3883

注意：添加的ip分别为三台虚拟机的ip，后面的端口也是防火墙需要打开的端口，不然无法彻底实现集群内部的网络互通
具体如何开放端口，请看Linux常用语句->防火墙部分
所涉及到的端口：
computer1:2181/2881/3881
computer2:2183/2882/3882
computer3:2183/2883/3883
检测是否防火墙已成功开启端口

telnet 192.168.227.12 3882

step5：将修改好的zoo.cfg文件复制到computer2和computer3中，需要对应修改的部分如下
在这里插入图片描述
zk1 ->zk2 zk3
2181 ->2182 2183
step6：data 目录下创建一个 myid 文件，内容为1

cd /usr/local/zookeeper/zk1/data
echo 1 >myid

computer1和computer2也相同操作

5. 启动集群
cd /usr/local/zookeeper/zk1/bin
./zkServer.sh start

cd /usr/local/zookeeper/zk2/bin
./zkServer.sh start

cd /usr/local/zookeeper/zk3/bin
./zkServer.sh start
6. 查看启动状态
cd /usr/local/zookeeper/zk1/bin
./zkServer.sh status

cd /usr/local/zookeeper/zk2/bin
./zkServer.sh status

cd /usr/local/zookeeper/zk3/bin
./zkServer.sh status
Error contacting service. It is probably not running

ps：这里我出现了一个错误：
在这里插入图片描述
解决思路：
需要telnet ip 端口，看是否通，首先确认本机和虚拟机之间能telnet通，然后确认虚拟机和虚拟机之间能telnet通，然后执行“./zkServer.sh restart”，即可解决

成功的状态：
在这里插入图片描述

搭建kafka集群 1. 下载

下载网址：https://kafka.apache.org/downloads
在这里插入图片描述

2. 上传

新建kafka目录

cd /usr/local
mkdir kafka
3. 解压
tar -zxvf kafka_2.12-3.3.1.tgz
4. 更改文件夹名称
mv kafka-3.3.1-src kafka
5. 新建logs文件夹
cd /usr/local/kafka/kafka
mkdir logs
6. 修改配置文件
vi /usr/local/kafka/kafka/config/server.properties

修改如下配置

①
broker.id=0  #集群里需要用不用的id号
②
listeners=PLAINTEXT://192.168.227.12:9092
③
log.dirs=/usr/local/kafka/kafka/logs
④
zookeeper.connection=192.168.227.11:2181,192.168.227.12:2182,192.168.227.13:2183
⑤
delete.topic.enable=true
7. 将修改后的文件扩展到computer02和computer03 8. 启动kafka
cd /usr/local/kafka/kafka/bin
./kafka-server-start.sh ../config/server.properties

在这里插入图片描述
启动成功之后是一个阻塞进程，需要打开新的窗口操作

使用kafka 1. 创建topic

后续持续更新中~

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧


本文名称：从新建linux虚拟机到搭建zookeeper+kafka详细版-创新互联
网页链接：http://myzitong.com/article/hdchi.html

其他资讯