ubuntu下如何搞定kafka配置

在Ubuntu下配置Apache Kafka可以分为以下几个步骤：

1. 安装Java环境

Kafka需要Java运行时环境，因此首先需要安装Java。可以使用以下命令安装OpenJDK 8：

sudo apt update sudo apt install openjdk-8-jdk 

验证Java安装成功：

java -version 

2. 下载并解压Kafka

从Apache Kafka官网下载最新版本的Kafka，例如Kafka 2.8.0：

wget https://mirror-hk.koddos.net/apache/kafka/2.8.0/kafka_2.13-2.8.0.tgz 

解压下载的tgz文件：

tar -zxvf kafka_2.13-2.8.0.tgz 

3. 配置Zookeeper

Kafka依赖Zookeeper进行协调。首先，需要配置Zookeeper。

3.1 创建Zookeeper配置文件

在Kafka解压目录下创建zookeeper.properties文件：

mkdir -p /opt/kafka/config 

编辑zookeeper.properties文件：

sudo vi /opt/kafka/config/zookeeper.properties 

添加或修改以下配置：

dataDir=/home/XXX/kafka/zookeeper/data dataLogDir=/home/XXX/kafka/zookeeper/logs clientPort=2181 maxClientCnxns=100 tickTime=2000 initLimit=10 

3.2 启动Zookeeper

在Kafka解压目录下的bin目录中，启动Zookeeper：

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

4. 配置Kafka

4.1 编辑Kafka配置文件

进入Kafka解压目录，编辑server.properties文件：

sudo vi /opt/kafka/config/server.properties 

添加或修改以下配置：

broker.id=0 listeners=PLAINTEXT://your_server_ip:9092 advertised.listeners=PLAINTEXT://your_server_ip:9092 zookeeper.connect=localhost:2181 log.dirs=/home/XXX/kafka/log 

4.2 创建Kafka启动脚本

创建一个启动脚本kafka_start.sh：

touch /opt/kafka/kafka_start.sh chmod +x /opt/kafka/kafka_start.sh 

编辑kafka_start.sh文件：

#!/bin/bash # 启动Zookeeper /opt/kafka/bin/zookeeper-server-start.sh ../config/zookeeper.properties & # 启动Kafka /opt/kafka/bin/kafka-server-start.sh ../config/server.properties & 

5. 启动Kafka服务

执行启动脚本启动Kafka：

./kafka_start.sh 

6. 验证Kafka配置

6.1 创建Topic

创建一个测试Topic以验证Kafka是否正常运行：

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 

6.2 生产者和消费者测试

启动生产者发送消息：

./kafka-console-producer.sh --broker-list localhost:9092 --topic test 

启动消费者消费消息：

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

7. 关闭Kafka服务

停止Kafka服务：

./kafka_stop.sh 

停止Zookeeper服务：

./zookeeper-server-stop.sh