在 Ubuntu 上配置 Apache Kafka 需要几个步骤,包括安装 Java、下载 Kafka、配置 Kafka 服务器和客户端。以下是一个详细的指南:
Kafka 需要 Java 运行环境。你可以使用 OpenJDK 或 Oracle JDK。以下是安装 OpenJDK 的步骤:
sudo apt update
sudo apt install openjdk-11-jdk
验证 Java 安装:
java -version
访问 Apache 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
Kafka 使用 Zookeeper 进行集群管理。首先启动 Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
在另一个终端窗口中启动 Kafka 服务器:
bin/kafka-server-start.sh config/server.properties
创建一个 Kafka 主题,例如 my-topic
:
bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
列出所有主题以验证 my-topic
是否已创建:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
查看 my-topic
的详细信息:
bin/kafka-topics.sh --describe --topic my-topic --bootstrap-server localhost:9092
你可以使用 Kafka 自带的命令行工具来生产和消费消息。
发送消息到 my-topic
:
bin/kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092
在终端中输入消息并按回车键发送。
从 my-topic
消费消息:
bin/kafka-console-consumer.sh --topic my-topic --from-beginning --bootstrap-server localhost:9092
这将显示 my-topic
中的所有消息。
Kafka 的配置文件位于 config
目录下。你可以根据需要修改这些文件来调整 Kafka 的行为。例如,你可以修改 server.properties
文件来更改 Kafka 服务器的配置。
停止 Kafka 服务器:
bin/kafka-server-stop.sh
停止 Zookeeper:
bin/zookeeper-server-stop.sh
通过以上步骤,你已经在 Ubuntu 上成功配置了 Apache Kafka。你可以根据需要进一步调整和扩展 Kafka 的配置。