Centos7.6单机部署Kafka

Centos7.6单机部署Kafka

安装Java环境

# 安装OpenJDK 8
yum install -y java-1.8.0-openjdk

# 验证安装
java -version

下载并解压Kafka

# 下载kafka
wget https://downloads.apache.org/kafka/3.7.2/kafka_2.12-3.7.2.tgz 

# 解压
tar -zxvf kafka_2.12-3.7.2.tgz  -C /opt/

# 进入到kafka目录
cd /opt/kafka_2.13-3.7.0

配置ZooKeeper（单机模式）

Kafka依赖ZooKeeper，单机模式下可使用内置的ZooKeeper。

修改ZooKeeper配置（可选）：

vim config/zookeeper.properties

dataDir=/tmp/zookeeper
clientPort=2181

配置Kafka

修改Kafka配置文件：

vim config/server.properties

关键配置项：

# 监听地址（确保客户端可以访问）
listeners=PLAINTEXT://0.0.0.0:9092

# 日志存储目录
log.dirs=/tmp/kafka-logs

# 广告地址（若需远程访问，填写本机IP或域名）
advertised.listeners=PLAINTEXT://<服务器IP>:9092

启动服务

启动zookeeper

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &

启动kafka

nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &

验证服务

创建测试主题

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

查看主题列表

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

生产消息

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

消费消息（新终端）

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

停止服务

# 停止Kafka
bin/kafka-server-stop.sh

# 停止ZooKeeper
bin/zookeeper-server-stop.sh