在Ubuntu上部署Apache Kafka需要几个步骤。以下是一个基本的指南,帮助你在Ubuntu系统上安装和运行Kafka。
Java JDK: Kafka需要Java运行环境。确保你的系统上安装了Java JDK。可以使用以下命令安装OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
确认安装成功:
java -version
下载Kafka:
从Kafka官方网站下载最新版本的Kafka。你可以使用wget
命令下载:
wget https://downloads.apache.org/kafka/3.5.1/kafka_2.13-3.5.1.tgz
请根据最新的稳定版本替换URL中的版本号。
解压Kafka:
下载完成后,解压缩文件:
tar -xzf kafka_2.13-3.5.1.tgz
cd kafka_2.13-3.5.1
启动Zookeeper:
Kafka使用Zookeeper进行管理。首先启动Zookeeper服务:
bin/zookeeper-server-start.sh config/zookeeper.properties
Zookeeper默认会在2181
端口运行。
启动Kafka服务器:
在另一个终端窗口中,启动Kafka服务器:
bin/kafka-server-start.sh config/server.properties
Kafka默认会在9092
端口运行。
创建测试主题:
创建一个名为test
的主题来测试Kafka:
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
列出所有主题:
确认主题已经创建成功:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
生产消息:
向test
主题发送一条消息:
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
输入消息并按回车发送。
消费消息:
从test
主题读取消息:
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
你应该能看到刚才发送的消息。
Kafka的配置文件位于config
目录下。你可以根据需要修改这些配置文件来调整Kafka的行为。例如,你可以编辑server.properties
来更改监听端口、日志目录等。
通过以上步骤,你应该能够在Ubuntu系统上成功部署和运行Apache Kafka。