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 後台啟動的方法。