安装Java环境

在oracle官网下载jdk1.8 ，官网地址https://www.oracle.com/java/technologies/downloads/#java8。

上传JDK

下载完成后上传到用户根目录并重命名为jdk.tar.gz：

tar -xf jdk.tar.gz -C /opt/jdk

配置环境变量

echo "" >> /etc/profile
echo "# JDK 8 Environment Variables" >> /etc/profile
echo "export JAVA_HOME=/opt/jdk" >> /etc/profile
echo "export PATH=\$PATH:\$JAVA_HOME/bin" >> /etc/profile
source /etc/profile

验证安装

[root@test1 ~]# java -version
java version "1.8.0_391"
Java(TM) SE Runtime Environment (build 1.8.0_391-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.391-b13, mixed mode)

安装Kafka最新版本

在写这篇文章的时候，目前最新版本是3.6.0版本

下载最新版本

cd /opt && wget https://downloads.apache.org/kafka/3.6.0/kafka_2.13-3.6.0.tgz 

解压

tar -xzf kafka_2.13-3.6.0.tgz

配置Kafka

1. 进入解压目录：

   cd kafka_2.13-3.6.0

2. 打开config/server.properties文件进行配置：

   vi config/server.properties

   根据自己的需求进行调整：

   • broker.id：Kafka代理的唯一标识符。
   • listeners：Kafka监听器的主机和端口。默认情况下，Kafka使用PLAINTEXT://:9092。
   • log.dirs：Kafka日志文件的目录。
   • zookeeper.connect：Zookeeper的主机和端口。默认情况下，Kafka使用localhost:2181。

启动Kafka

# 先启动 zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 再启动 kafka
bin/kafka-server-start.sh -daemon config/server.properties

验证

以下的所有操作都是在/opt/kafka_2.13-3.6.0中进行：

1. 创建主题

   bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

2. 发布消息到test-topic主题：

   bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092

3. 在新终端窗口中，消费来自test-topic主题的消息：

   bin/kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning