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

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>