在 Ubuntu 上配置 Apache Kafka 需要几个步骤,包括安装 Java(Kafka 的依赖项)、下载 Kafka、配置 Kafka 服务器和客户端。以下是一个基本的指南:
Kafka 需要 Java 运行环境。你可以通过以下命令安装 OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
安装完成后,你可以通过运行 java -version 来验证 Java 是否安装成功。
你可以从 Kafka 官方网站下载最新版本的 Kafka。使用 wget 命令下载并解压:
wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0
请确保替换 URL 中的版本号为你想要下载的 Kafka 版本。
Kafka 使用 Zookeeper 来管理集群和元数据。首先,你需要启动 Zookeeper:
# 启动 Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
Zookeeper 默认会在端口 2181 上运行。你可以通过运行 bin/zkServer.sh status 来检查 Zookeeper 的状态。
接下来,启动 Kafka 服务器:
# 启动 Kafka 服务器
bin/kafka-server-start.sh config/server.properties
Kafka 默认会在端口 9092 上运行。你可以通过运行 bin/kafka-topics.sh --list --bootstrap-server localhost:9092 来检查 Kafka 是否正在运行。
你可以使用 Kafka 提供的命令行工具来创建一个新的主题:
# 创建一个名为 "test" 的主题,只有一个分区,复制因子为 1
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
你可以在 config 目录下的 server.properties 文件中配置 Kafka 服务器的设置。对于客户端,你可以在 config 目录下创建一个新的文件,例如 client.properties,并进行相应的配置。
Kafka 提供了生产者和消费者命令行工具,你可以使用它们来发送和接收消息。
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
在提示符下输入消息,按 Enter 发送。
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
这将显示主题 “test” 中的所有消息。
以上步骤提供了一个基本的 Kafka 配置指南。根据你的具体需求,可能需要进行更多的配置和优化。