一、下载 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 后台启动的方法。