Logo
linux LI
以下是在 Linux 系统上安装 Kafka 的详细步骤和命令。

下载 Kafka
首先,您需要下载 Kafka,可以从官网下载最新版本的 Kafka。假设您要下载的是 Kafka 2.9.2 版本,可以使用以下命令下载:

bash
wget https://archive.apache.org...
解压 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 系统
2 年 以前

还没有回复!

这条推文似乎还没有发表任何回复。您可以通过点击本推文 linux LI左下方的 图标回复此帖。