以下是在 Linux 系统上安装 Kafka 的详细步骤和命令。
- 下载 Kafka
首先，您需要下载 Kafka，可以从官网下载最新版本的 Kafka。假设您要下载的是 Kafka 2.9.2 版本，可以使用以下命令下载：
bash
wget https://archive.apache.org/dist/kafka/2.9.2/kafka_2.9.2-0.8.1.1.tgz
- 解压 Kafka
下载完成后，将下载的文件解压缩到您的喜欢目录。可以使用以下命令解压：
bash
tar -xzf kafka_2.9.2-0.8.1.1.tgz
cd kafka_2.9.2-0.8.1.1
- 启动 ZooKeeper
Kafka 依赖于 ZooKeeper，因此需要在启动 Kafka 之前启动 ZooKeeper。可以使用以下命令启动 ZooKeeper：
bash
bin/zookeeper-server-start.sh config/zookeeper.properties
- 启动 Kafka 服务
在启动 Kafka 服务之前，需要编辑 config/server.properties 文件，确保 Kafka 的配置正确。您可以使用以下命令编辑配置文件：
bash
nano config/server.properties
在文件中，您需要检查以下配置：
javascript
broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs
完成后，使用以下命令启动 Kafka 服务：
bash
bin/kafka-server-start.sh config/server.properties
- 创建主题
启动 Kafka 服务后，您可以使用以下命令创建一个名为 “test” 的主题：
bash
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 发布和接收消息
使用以下命令向 “test” 主题发布消息：
bash
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
使用以下命令从 “test” 主题接收消息：
python
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
以上是在 Linux 系统上安装和配置 Kafka 的基本步骤和命令。请根据您的环境和需求进行修改和调整。
THE END
暂无评论内容