ubuntu里kafka配置步骤是什么

以下是在Ubuntu上配置Kafka的步骤：

1. 安装Java环境

   sudo apt update  
   sudo apt install openjdk-8-jdk  # 推荐OpenJDK 8  
   java -version  # 验证安装  
   

2. 安装Zookeeper（Kafka依赖）

   • 下载解压：

     wget https://downloads.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz  
     tar -xzf apache-zookeeper-3.8.0-bin.tar.gz  
     sudo mv apache-zookeeper-3.8.0 /usr/local/zookeeper  
     

   • 配置zoo.cfg：

     sudo vi /usr/local/zookeeper/conf/zoo.cfg  
     # 修改以下内容：  
     dataDir=/var/lib/zookeeper  
     clientPort=2181  
     

   • 启动Zookeeper：

     sudo /usr/local/zookeeper/bin/zkServer.sh start  
     sudo netstat -nap | grep 2181  # 验证端口  
     

3. 安装Kafka

   • 下载解压：

     wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz  
     tar -xzf kafka_2.12-3.5.2.tgz  
     sudo mv kafka_2.12-3.5.2 /usr/local/kafka  
     

   • 创建日志目录：

     sudo mkdir -p /usr/local/kafka/logs  
     

4. 配置Kafka
   编辑server.properties：

   sudo vi /usr/local/kafka/config/server.properties  
   # 关键配置：  
   broker.id=0  # 集群中唯一ID  
   listeners=PLAINTEXT://0.0.0.0:9092  # 监听地址  
   advertised.listeners=PLAINTEXT://your_server_ip:9092  # 对外可访问地址  
   log.dirs=/usr/local/kafka/logs  
   zookeeper.connect=localhost:2181  
   

5. 启动Kafka

   • 直接启动（非集群模式）：

     sudo /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties  
     

   • 配置Systemd服务（可选，用于开机自启）：
     创建服务文件/etc/systemd/system/kafka.service，内容参考，然后执行：

     sudo systemctl daemon-reload  
     sudo systemctl start kafka  
     sudo systemctl enable kafka  
     

6. 验证与测试

   • 查看Kafka是否监听端口：

     sudo netstat -tulnp | grep 9092  
     

   • 创建Topic并测试消息：

     # 创建Topic  
     sudo /usr/local/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1  
     # 生产者发送消息  
     sudo /usr/local/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test  
     # 消费者接收消息  
     sudo /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning  
     

注意：

• 若需集群部署，需在多台机器上重复上述步骤，确保broker.id唯一，并正确配置listeners和advertised.listeners。
• 生产环境建议关闭Zookeeper内置模式，使用独立部署的Zookeeper集群。