Kafka

卸载自带jdk

提示

在安装之前，需要查看Linux系统本身是不是自带了jdk，如果自带jdk，那么需要卸载之后再安装。 步骤： 使用 java -version 命令查看系统自带jdk版本信息 如果存在，则输入 rpm -qa | grep java 搜索jdk具体信息 验证是否删除干净 至此，系统自带jdk卸载完成，开始安装jdk

#搜索jdk具体信息
rpm -qa | grep jdk
#把带有jdk关键字的卸载掉
rpm -e --nodeps jdk1.8-1.8.0_351-fcs.x86_64

下载JDK

# 链接：链接：链接：https://pan.baidu.com/s/1LzlVcG5TwWRnruSgpv0hmg?pwd=jxlt
# 下载完后上传至服务器
# 添加执行权限
chmod +x jdk-11.0.17_linux-x64_bin.rpm

安装JDK并配置环境变量

# 执行安装命令
rpm -ivh jdk-11.0.17_linux-x64_bin.rpm

# 验证是否生效
java -version

# 如果没有生效，则配置相关环境变量
# 查看安装路径
rpm -qpl jdk-11.0.17_linux-x64_bin.rpm


# 配置jdk环境变量
vi /etc/profile
###################
export JAVA_HOME=/usr/java/jdk-11.0.17
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

# 验证是否生效
java -version

安装Kafka

#下载kafka
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.2/kafka_2.12-2.8.2.tgz

#解压kafka并启动kafka
tar -xzf kafka_2.12-2.8.2.tgz -C /usr/local
cd /usr/local
mv kafka_2.12-2.8.2 kafka
cd kafka
#启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
#开启kafka服务
bin/kafka-server-start.sh -daemon config/server.properties

### 防火墙放开端口
firewall-cmd --add-port=2181/tcp --permanent
firewall-cmd --reload

验证是否正常

### 创建topic
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
## 生成消息
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
## 消费消息
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

kafka took可视化工具下载

https://www.kafkatool.com/download.html