在Ubuntu系统上安装Apache Kafka的步骤如下:
1. 安装Java环境
Kafka需要Java环境,因此首先需要安装Java。可以通过以下命令安装OpenJDK 11:
sudo apt update
sudo apt install openjdk-11-jdk -y
然后检查Java版本:
java -version
2. 下载Apache Kafka
访问Apache Kafka官网下载最新版本的Kafka,或者使用wget命令直接下载:
wget https://downloads.apache.org/kafka/3.5.1/kafka_2.13-3.5.1.tgz
请替换上述链接中的版本号为你需要的版本。
3. 解压Kafka压缩包
tar -xzf kafka_2.13-3.5.1.tgz
4. 移动Kafka到合适的目录
建议将Kafka移动到/usr/local
目录下:
sudo mv kafka_2.13-3.5.1 /usr/local/kafka
5. 设置环境变量(可选)
为了方便使用,可以设置环境变量:
echo 'export KAFKA_HOME=/usr/local/kafka' >> ~/.bashrc
echo 'export PATH=$PATH:$KAFKA_HOME/bin' >> ~/.bashrc
source ~/.bashrc
这样你就可以直接使用kafka-server-start
、kafka-topics
等命令了。
6. 启动ZooKeeper
Kafka使用ZooKeeper来维护集群元数据,因此需要先启动ZooKeeper:
sudo /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties
7. 启动Kafka服务
sudo /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
这将在后台启动Kafka服务。
8. 创建Kafka Topic
使用以下命令创建一个Kafka Topic:
kafka-topics.sh --create --topic test-topic --zookeeper localhost:2181 --partitions 1 --replication-factor 1
9. 验证Kafka和Topic
使用以下命令列出所有的Kafka Topics:
kafka-topics.sh --list --zookeeper localhost:2181
10. 停止Kafka和ZooKeeper
当你完成测试后,可以使用以下命令停止Kafka和ZooKeeper服务:
sudo /usr/local/kafka/bin/kafka-server-stop.sh
sudo /usr/local/kafka/bin/zookeeper-server-stop.sh
以上步骤提供了一个基本的指南来在Ubuntu系统上安装和启动Apache Kafka。确保在安装过程中,你已经满足了所有环境要求,包括安装了正确版本的Java和ZooKeeper。