首页 > 系统相关 >centos7搭建kafka

centos7搭建kafka

时间:2023-01-06 16:56:54浏览次数:41  
标签:bin zookeeper kafka centos7 sh usr local 搭建

一、安装 java8

yum install java-1.8.0-openjdk.x86_64
yum install java-1.8.0-openjdk-devel.x86_64

二、安装 Zookeeper

1. 下载zookeeper

wget https://archive.apache.org/dist/zookeeper/zookeeper-3.5.9/apache-zookeeper-3.5.9-bin.tar.gz

2. 解压

tar -zxvf apache-zookeeper-3.5.9-bin.tar.gz

3. 移动重命名

mv apache-zookeeper-3.5.9-bin /usr/local/zookeeper

4. 进入conf文件夹,复制zoo_sample.cfg命名为zoo.cfg

cd /usr/local/zookeeper/conf/
cp zoo_sample.cfg zoo.cfg

5. 修改zoo.cfg中配置,改好后保存

vim zoo.cfg

dataDir=/data/zookeeper
dataLogDir=/data/log/zookeeper

6. 编辑 /etc/profile, 在文件末尾追加内容

vim /etc/profile
#zookeeper-3.5.9 config start
export ZOOKEEPER_HOME=/usr/local/zookeeper
export PATH=$ZOOKEEPER_HOME=/bin/$PATH
export PATH
#zookeeper-3.5.9 config end

7. 生效profile

 source /etc/profile

8. 启动zookeeper

cd /usr/local/zookeeper/bin/

# 启动zookeeper
./zkServer.sh start

# 查看zookeeper状态
./zkServer.sh status

# 关闭zookeeper服务
./zkServer.sh stop

# 重启zookeeper服务
./zkServer.sh restart

9. 设置服务和开机启动

 添加到服务管理

vim /usr/lib/systemd/system/zookeeper.service

添加以下内容后,保存

[Unit]
Description=zookeeper-3.5.9
After=syslog.target network.target

[Service]
Restart=alwaysRestartSec=1
Type=forking
TimeoutSec=120

User=root

ExecStart=/usr/local/zookeeper/bin/zkServer.sh start
ExecStop=/usr/local/zookeeper/bin/zkServer.sh stop
ExecReload=/usr/local/zookeeper/bin/zkServer.sh restart

Restart=always

[Install]
WantedBy=multi-user.target

生效服务及开机自启动

systemctl daemon-reload
systemctl enable zookeeper.service

启动

# 启动
systemctl start zookeeper
# 查看状态
systemctl status zookeeper
# 停止
systemctl stop zookeeper

三、安装 kafka

1、下载

wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz

2、解压

tar -zxvf kafka_2.13-3.3.1.tgz

3、移动重命名

mv kafka_2.13-3.3.1 /usr//local/kafka

4、配置KAFKA外网访问

cd /usr/local/kafka/config/
vim server.properties

#放开注释
listeners=PLAINTEXT://:9092
#放开注释并修改
advertised.listeners=PLAINTEXT://172.17.0.3:9092

5、配置KAFKA log路径

vim server.properties
log.dirs=/software/kafka/kafka-logs

6、配置zookeeper数据路径

#在目录下创建zookeeper文件夹用来存放数据
cd /usr/local/kafka
mkdir zookeeper

#打开config目录下的zookeeper.properties文件修改配置
cd /usr/local/kafka/config
vim zookeeper.properties

dataDir=/usr/local/kafka/zookeeper

7、启动KAFKA

cd /usr/local/kafka
 # 启动zookeeper
 bin/zookeeper-server-start.sh config/zookeeper.properties
 ​
 # 启动kafka
 bin/kafka-server-start.sh config/server.properties
 ​
 # 生产消息(创建名为testTopic的主题)
 bin/kafka-console-producer.sh --topic testTopic --bootstrap-server localhost:9092
 ​
 # 监听消息(重开一个终端监听testTopic主题的消息,在生产消息的终端发消息,此终端收消息)
 bin/kafka-console-consumer.sh --topic testTopic --from-beginning --bootstrap-server localhost:9092

 

标签:bin,zookeeper,kafka,centos7,sh,usr,local,搭建
From: https://www.cnblogs.com/shenqilun/p/17030952.html

相关文章

  • gitolite安装及配置教程centos7
     1. 安装依赖包yuminstallcurl-develexpat-develgettext-developenssl-develzlib-develperl-devel-y 2.安装Gityum-yinstallgit 3.创建git用户useraddgitp......
  • centos7的telnet不通已经关闭防火墙,打开阿里云端口仍然ping不通的解决办法
    1.firewall-cmd--permanent--add-port=5672/tcpfirewall-cmd--reloadsetsebool-Pnis_enabled1 (关闭selinux)2.粗暴的方法systemctlstopfirewalldsystemctldisable......
  • linux的centos7安装mysql5.7服务教程
    1.使用yum安装,便捷,快速MySQLYumRepositoryMySQL官方新提供了一种安装MySQL的方法--使用YUM源安装MySQL.1、MySQL官方网站下载MySQL的YUM源,在MySQL的下载页有一个“NEW!My......
  • NoneBot2搭建QQ聊天机器人
    1、下载python,版本不低于3.8官网:https://www.python.org/downloads/2、构建python虚拟环境(强烈推荐,当然也可以跳过此步骤)#cmd命令行pipinstallvirtualenvwap......
  • kafka学习总结018 --- 消息过期设置
    一、kafka全局消息过期时间设置目录:kafka_2.13-3.3.1/config/server.properties#Theminimumageofalogfiletobeeligiblefordeletionduetoagelog.retentio......
  • docker安装centos7
    一、查看可用的CentOS版本访问CentOS镜像库地址:https://hub.docker.com/_/centos?tab=tags&page=1。可以通过Sortby查看其他版本的CentOS。默认是最新版本cent......
  • Redis哨兵模式搭建
    一:哨兵主要作用监控:监控redis主库及从库运行状态;通知:如果redis发生故障转移,可以通过邮件通知管理员;自动故障转移:一旦发现主库宕机,则在从库中通过选举新的master进行故......
  • CentOS7.9下配置安装KVM虚拟机
     一、准备工作:1.关闭selinux、防火墙##关闭selinux#sed-i's/SELINUX=enforcing/SELINUX=disabled/g'/etc/selinux/config#永久生效,但是必须要重启系统。##立......
  • centos7下docker设置阿里云镜像(自定义阿里云镜像)
    1、登陆自己的阿里云aliyun.com2、找到容器镜像服务3、找到镜像加速器4、打开文件/etc/docker/daemon.json将圈起来的字符串替换掉如下图所示5、重新加载daemon以及重启dock......
  • 直播平台搭建源码,更改图片透明度
    直播平台搭建源码,更改图片透明度 publicpartialclassForm1:Form{  publicForm1()  {    InitializeComponent();  }  Imagenew_img; ......