一、下载 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 后台启动的方法。
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/252108.html
微信扫一扫 
支付宝扫一扫 