Kafka消息队列在Linux上怎么用

以下是在Linux上使用Kafka消息队列的步骤，以单机部署为例：

一、环境准备

1. 安装Java（Kafka依赖Java 8+）：

   # Ubuntu/Debian  
   sudo apt update && sudo apt install openjdk-11-jdk -y  
   # CentOS/RHEL  
   sudo yum install java-11-openjdk -y  
   java -version  # 验证安装  
   

2. 下载并解压Kafka：

   wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz  
   tar -xzf kafka_2.13-3.6.1.tgz  
   mv kafka_2.13-3.6.1 /opt/kafka  
   cd /opt/kafka  
   

二、配置Kafka

修改config/server.properties关键参数：

broker.id=0  
listeners=PLAINTEXT://localhost:9092  # 监听地址  
log.dirs=/tmp/kafka-logs  # 日志目录  
zookeeper.connect=localhost:2181  # ZooKeeper地址（单机版可内置）  

三、启动服务

1. 启动ZooKeeper（Kafka 2.8+版本需手动启动，旧版本内置）：

   bin/zookeeper-server-start.sh -daemon config/zookeeper.properties  
   

2. 启动Kafka：

   bin/kafka-server-start.sh -daemon config/server.properties  
   

四、测试消息队列

1. 创建Topic：

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

2. 发送消息（生产者）：

   bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092  
   # 输入消息后按Enter发送  
   

3. 消费消息（消费者）：

   bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092  
   # 查看历史消息  
   

五、停止服务

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

关键说明

• 端口配置：确保9092（Kafka）、2181（ZooKeeper）未被占用，可通过sudo firewall-cmd --add-port=9092/tcp开放防火墙。
• 生产环境建议：使用独立磁盘存储日志（修改log.dirs）、配置多节点集群提升可用性。
• 集群部署：需配置多节点ZooKeeper和Kafka，设置broker.id和zookeeper.connect参数。

以上步骤参考自，可根据实际需求调整配置。