您的位置:

Kafka 后台启动

一、下载 Kafka

首先,在官网下载 Kafka 的二进制文件:

wget https://www-us.apache.org/dist/kafka/2.7.0/kafka_2.12-2.7.0.tgz
tar -xzf kafka_2.12-2.7.0.tgz
cd kafka_2.12-2.7.0

解压后,进入 Kafka 安装目录。

二、配置 ZooKeeper

Kafka 是基于 ZooKeeper 来实现集群功能的,所以启动 Kafka 之前必须先启动 ZooKeeper。

在 Kafka 安装目录下创建一个名为 "data" 的文件夹,用于存放 ZooKeeper 的数据:

mkdir data

编辑 Kafka 安装目录下的 "config/zookeeper.properties",修改其中的 "dataDir" 为上一步创建的 "data" 目录:

dataDir=/your/path/to/kafka/data

现在就可以启动 ZooKeeper 了:

bin/zookeeper-server-start.sh config/zookeeper.properties

查看 ZooKeeper 是否启动成功:

telnet localhost 2181

如果返回如下信息,则表示启动成功:

 Trying 127.0.0.1...
 Connected to localhost.
 Escape character is '^]'.

三、配置 Kafka

编辑 Kafka 安装目录下的 "config/server.properties",根据需要修改以下参数:

  • broker.id:设置 Broker 的唯一 ID,集群中每个 Broker 的 ID 必须是唯一的。
  • listeners:配置 Broker 监听的端口。
  • log.dirs:指定 Kafka 存储消息的磁盘目录。
  • num.partitions:指定默认主题的分区数。

配置好后保存文件,然后就可以启动 Kafka 了:

bin/kafka-server-start.sh config/server.properties

查看 Kafka 是否启动成功:

bin/kafka-topics.sh --zookeeper localhost:2181 --list

如果命令返回空行,则表示 Kafka 启动成功。

四、创建主题

创建一个名为 "test_topic" 的主题:

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test_topic

查看 Kafka 中已经创建的主题:

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

如果列表中包含 "test_topic",则表示主题创建成功。

五、发送消息

使用 Kafka 中提供的 "kafka-console-producer.sh" 工具发送消息:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic

启动之后,输入消息即可发送到 Kafka,例如:

hello world

发送消息之后,使用 "kafka-console-consumer.sh" 工具接收消息:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning

如果成功接收到刚才发送的消息,则表示 Kafka 配置成功。

六、总结

本篇文章主要介绍了 Kafka 后台启动的步骤,从下载 Kafka、配置 ZooKeeper、配置 Kafka、创建主题、发送消息等多个方面详细介绍了 Kafka 启动的步骤。相信通过本篇文章的介绍,您已经掌握了 Kafka 后台启动的方法。