Kafka的常用命令（包括：下载安装、后台启动）

Bertha 。 2023-09-29 09:32 8阅读 0赞

### 一、环境准备 ###

首先JDK要在1.8及以上；然后安装对应版本的zookeeper。  
本文以`kafka2.7.2`为例，关于如何找到kafka对应的zookeeper版本，参考我的这篇文章：[如何确定kafka与zookeeper版本的对应关系][kafka_zookeeper]。

#### 1、安装Zookeeper3.5.9 ####

Zookeeper下载地址：[https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.5.9/apache-zookeeper-3.5.9-bin.tar.gz][https_mirrors.tuna.tsinghua.edu.cn_apache_zookeeper_zookeeper-3.5.9_apache-zookeeper-3.5.9-bin.tar.gz]，  
更多版本查看：[https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/][https_mirrors.tuna.tsinghua.edu.cn_apache_zookeeper]。

**1）解压zookeeper压缩包**

tar -zxvf apache-zookeeper-3.5.9-bin.tar.gz

**2）复制并修改配置文件**

# 进入到./zookeeper01/conf目录下
    cd ./apache-zookeeper-3.5.9-bin/conf
    # 复制配置文件
    cp zoo_sample.cfg zoo.cfg
    # 修改配置文件
    vi zoo.cfg

配置文件内容如下：

#服务器对应端口号
    clientPort=2181
    # 数据快照文件所在路径，需要先创建
    dataDir=/Users/zhouxin/software/apache-zookeeper-3.5.9-bin/data

**3）创建数据快照文件夹**

在上一步dataDir指定的目录下，创建相应目录

cd ../
    # 创建数据快照文件夹
    mkdir data

**4）启动zookeeper01服务**

cd ../bin
    ./zkServer.sh start

启动成功界面如下：  
![在这里插入图片描述][a45954239d104ed391081f9264228491.png]

**5）查看服务状态**

./zkServer.sh status

Zookeeper实例的状态如下：  
![在这里插入图片描述][c8e96455ef9c4010b26b92e76630c4fb.png]

### 二、下载并安装Kafka2.7.2 ###

官网下载路径：[https://kafka.apache.org/downloads][https_kafka.apache.org_downloads]；

**1）下载在kafka\_2.12-2.7.2；**  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA56eD5aS054ix5YGl6Lqr_size_16_color_FFFFFF_t_70_g_se_x_16]  
**2）解压Kafka压缩包：**

tar -zxvf kafka_2.12-2.7.2.tgz

**3）修改KafkaServer配置文件：**

1>> 进入kafka解压目录，找config文件夹下的server.properties文件：

cd kafka_2.12-2.7.2/config
    
    # 修改配置文件
    vi server.properties

修改点如下：

# 设置kafka消息存储目录
    log.dirs=/Users/zhouxin/software/kafka_2.12-2.7.2/data/kafka-logs

**3）修改zookeeper配置文件：**

找config文件夹下的zookeeper.properties；将其`dataDir=/tmp/zookeeper`修改为和我们安装Zookeeper配置的存储路径：`/Users/zhouxin/software/apache-zookeeper-3.5.9-bin/data`；

# 修改配置文件
    vi zookeeper.properties

修改点如下：

dataDir=/Users/zhouxin/software/apache-zookeeper-3.5.9-bin/data

**4）启动Kafka服务**

**1> Linux和Mac启动方式（前台启动）：**

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

**2> Window启动方式（前台启动）：**

cd ../bin/windows
    ./kafka-server-start.bat ../../config/server.properties

**启动成功界面如下：**  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA56eD5aS054ix5YGl6Lqr_size_20_color_FFFFFF_t_70_g_se_x_16]  
前台启动方式我们是不能关闭terminal的，我不想开着terminal，怎么办呢？后台启动撒！

#### 1/ 后台启动 ####

**3> Linux和Mac启动方式（后台启动）：**

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

windows上也一样，启动命令中加个`-daemon`即可；

### 三、常用命令 ###

#### 1、创建topic ####

创建一个名为saint-test-topic、副本数为1的topic

cd kafka_2.12-2.7.2/bin
    
    # 创建一个名为saint-test-topic、副本数为1的topic
    ./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic saint-test-topic

**创建topic成功界面如下：**  
![在这里插入图片描述][56b6f13a139548a29c6b036fb9542c15.png]

#### 2、查看topic列表 ####

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

**我只创建了一个topic，所以topic列表也就一个：**  
![在这里插入图片描述][1b73cc56d2c7473f97d1ddd880c81a95.png]

#### 3、生产者生产消息到指定topic ####

**1>> 开启Producer：**

./kafka-console-producer.sh --broker-list localhost:9092 --topic saint-test-topic

开启完Producer之后：  
![在这里插入图片描述][ae0e2c85a1df495c91dba4fa8724e6d4.png]

**2>> 发送消息：**  
![在这里插入图片描述][bac7f43c173a4ccd8f4e34808fa2934f.png]

#### 4、消费者消息指定topic的消息 ####

**这里的消费规则为：**

*  当前消费者作为消费组`consumer-group-1`的一员从`saint-test-topic` 主题中从offset头部开始消费消息：

./kafka-console-consumer.sh  --bootstrap-server localhost:9092 --topic saint-test-topic --group consumer-group-1 --from-beginning

![在这里插入图片描述][4253e9caa47944ffa99276cd23cab580.png]  
消费到消息之后，消费者处于持续接收消息的状态；

#### 5、查看kafka的broker集群配置： ####

##### 1> 查看broker所有节点的配置： #####

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-default --describe

![在这里插入图片描述][dab67dcc6ad340958ea106740eaf56e6.png]

##### 2> 查看某个broker节点（例如：0）的配置： #####

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --describe

![在这里插入图片描述][b3e4da36a69e4d55b197323459455afa.png]

[kafka_zookeeper]: https://blog.csdn.net/Saintmm/article/details/124073256
[https_mirrors.tuna.tsinghua.edu.cn_apache_zookeeper_zookeeper-3.5.9_apache-zookeeper-3.5.9-bin.tar.gz]: https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.5.9/apache-zookeeper-3.5.9-bin.tar.gz
[https_mirrors.tuna.tsinghua.edu.cn_apache_zookeeper]: https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/
[a45954239d104ed391081f9264228491.png]: https://img-blog.csdnimg.cn/a45954239d104ed391081f9264228491.png
[c8e96455ef9c4010b26b92e76630c4fb.png]: https://img-blog.csdnimg.cn/c8e96455ef9c4010b26b92e76630c4fb.png
[https_kafka.apache.org_downloads]: https://kafka.apache.org/downloads
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA56eD5aS054ix5YGl6Lqr_size_16_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/1831ad55faa84caa9069143c353e69de.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA56eD5aS054ix5YGl6Lqr,size_16,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA56eD5aS054ix5YGl6Lqr_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/fa15a5a37d5449af82b405d441a28ea0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA56eD5aS054ix5YGl6Lqr,size_20,color_FFFFFF,t_70,g_se,x_16
[56b6f13a139548a29c6b036fb9542c15.png]: https://img-blog.csdnimg.cn/56b6f13a139548a29c6b036fb9542c15.png
[1b73cc56d2c7473f97d1ddd880c81a95.png]: https://img-blog.csdnimg.cn/1b73cc56d2c7473f97d1ddd880c81a95.png
[ae0e2c85a1df495c91dba4fa8724e6d4.png]: https://img-blog.csdnimg.cn/ae0e2c85a1df495c91dba4fa8724e6d4.png
[bac7f43c173a4ccd8f4e34808fa2934f.png]: https://img-blog.csdnimg.cn/bac7f43c173a4ccd8f4e34808fa2934f.png
[4253e9caa47944ffa99276cd23cab580.png]: https://img-blog.csdnimg.cn/4253e9caa47944ffa99276cd23cab580.png
[dab67dcc6ad340958ea106740eaf56e6.png]: https://img-blog.csdnimg.cn/dab67dcc6ad340958ea106740eaf56e6.png
[b3e4da36a69e4d55b197323459455afa.png]: https://img-blog.csdnimg.cn/b3e4da36a69e4d55b197323459455afa.png