• CentOS7 安装 kafka

    目录

    一、安装 JDK

    1.安装jdk

    2.配置环境变量

    vim /etc/profile

    • 1

    在这里插入图片描述
    在最后面添加：

    export JAVA_HOME=/app/jdk-12.0.2
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin

    • 1
    • 2
    • 3
    • 4

    在这里插入图片描述

    3.执行profile文件：

    source /etc/profile

    • 1

    这样可以使配置文件立即生效

    二、安装 zookeeper

    官方地址：https://archive.apache.org/dist/zookeeper/zookeeper-3.7.0/

    mkdir /data
wget https://mirrors.bfsu.edu.cn/apache/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz -P /data --no-check-certificate
tar -zxvf /data/apache-zookeeper-3.7.0-bin.tar.gz

#修改配置文件
cd /data/apache-zookeeper-3.7.0-bin/conf
cp /data/apache-zookeeper-3.7.0-bin/conf/zoo_sample.cfg  /data/apache-zookeeper-3.7.0-bin/conf/zoo.cfg

vim /data/apache-zookeeper-3.7.0-bin/conf/zoo.cfg
dataDir=/data/apache-zookeeper-3.7.0-bin/data		#修改数据存放目录
dataLogDir=/data/apache-zookeeper-3.7.0-bin/logs
admin.serverPort=8081


......

mkdir -p /data/apache-zookeeper-3.7.0-bin/data		#创建 data 文件夹
mkdir -p /data/apache-zookeeper-3.7.0-bin/logs		#创建 log 文件夹

#启动 zookeeper
cd /data/apache-zookeeper-3.7.0-bin/bin
./zkServer.sh start
----------------------------------------------
nohup /data/apache-zookeeper-3.7.0-bin/bin/zkServer.sh start &
tail -f /data/apache-zookeeper-3.7.0-bin/bin/nohup.log
./zkServer.sh start-foreground		#查看启动失败错误信息，大概率是版本问题，要下带 bin 的版本

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26

    zokeeper一些操作

    启动服务：
/data/apache-zookeeper-3.7.0-bin/bin/zkServer.sh start
连接服务：
/data/apache-zookeeper-3.7.0-bin/bin/zkCli.sh
查看服务状态：
/data/apache-zookeeper-3.7.0-bin/bin/zkServer.sh status
停止服务：
/data/apache-zookeeper-3.7.0-bin/bin/zkServer.sh stop
#查看启动失败错误信息，大概率是版本问题，要下带 bin 的版本
./zkServer.sh start-foreground		

启动服务：
systemctl start zookeeper.service
查看服务状态：
systemctl status zookeeper.service



systemctl daemon-reload
systemctl enable zookeeper.service && systemctl restart zookeeper.service
systemctl status zookeeper.service


ps -ef|grep zookeeper

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24

    设置 zookeeper 开机自动启动

    cat > /usr/lib/systemd/system/zookeeper.service <
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    # 增加权限
chmod 777 /usr/lib/systemd/system/zookeeper.service

# 设置自启
systemctl enable zookeeper.service
systemctl daemon-reload

# 查看是否自启
systemctl is-enabled zookeeper.service

# 取消自启
systemctl disable zookeeper.service
systemctl daemon-reload


    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14

    配置zk环境变量

    vim /etc/profile

    • 1
    ZOOKEEPER_HOME=/data/apache-zookeeper-3.7.0-bin
PATH=$PATH:$ZOOKEEPER_HOME/bin
export PATH ZOOKEEPER_HOME PATH

    • 1
    • 2
    • 3

    在这里插入图片描述

    指定zookeeper启动JDK

    vim /data/apache-zookeeper-3.7.0-bin/bin/zkEnv.sh

    • 1

    添加 JAVA_HOME
    在这里插入图片描述

    三、安装 kafka

    官网：http://kafka.apache.org/downloads

    wget https://archive.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz -P /data --no-check-certificate
tar xf /data/kafka_2.12-2.8.0.tgz 


    • 1
    • 2
    • 3
    cd /data/kafka_2.12-2.8.0

vim /data/kafka_2.12-2.8.0/config/server.properties

    • 1
    • 2
    • 3

    在这里插入图片描述
    在这里插入图片描述

    启动Kafka：

    nohup /data/kafka_2.12-2.8.0/bin/kafka-server-start.sh ./config/server.properties &
或者
守护进程方式启动kafka:
/data/kafka_2.12-2.8.0/bin/kafka-server-start.sh -daemon /data/kafka_2.12-2.8.0/config/server.properties


    • 1
    • 2
    • 3
    • 4
    • 5

    设置开机自动启动

    cat > /usr/lib/systemd/system/kafka.service <
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18

    操作命令：

    systemctl daemon-reload
systemctl enable kafka.service && systemctl restart kafka.service
systemctl status kafka.service
netstat -antp | grep 9092
ps aux | grep kafka
lsof -i:9092
jps -l

nohup /data/kafka_2.12-2.8.0/bin/kafka-server-start.sh ./config/server.properties &

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

    四. 测试kafka

    1.创建 Topic
/data/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --zookeeper localhost:3181 --replication-factor 1 --partitions 1 --topic test

2.查看 topic 列表
/data/kafka_2.12-2.8.0/bin/kafka-topics.sh --list --zookeeper localhost:3181


3.查看描述 topics 信息

/data/kafka_2.12-2.8.0/bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

4.启动生产者（窗口不要关闭）
/data/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

5.启动消费者（窗口不要关闭）
/data/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

6.在生产者窗口输入内容，消费者端可查看到输入的内容
生产端：
{"id":"1"}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20

    在这里插入图片描述

    在这里插入图片描述

  • 相关阅读:
    C++入门04—数组与函数
    在 Android 应用程序开发期间减少 Android 应用程序大小的 9 种方法
    Redis简单介绍以及使用
    【附源码】计算机毕业设计JAVA疫情下的进出口食品安全信息管理系统
    大数据课程L5——网站流量项目的实时业务系统搭建
    手机通用便签APP哪个比较好用？
    【云计算】云数据中心网络（七）：负载均衡
    Linux安全—linux三剑客之sed（持续更新）
    linux k8s之KubeSphere启用DevOps
    “趣说“Sybase ASE中有关字段大小计算
  • 原文地址：https://blog.csdn.net/q908544703/article/details/125995760