---
title: 运行验证
description: "Kafka安装包在鲲鹏环境安装时，需要依赖bigtop-utils、zookeeper等包，读者在执行本章节验证前，需完成环境搭建工作，在相关的环境依赖具备条件下，kafka的安装只需要通过最普通的RPM包安装命令（rpm -ivh xx.rpm）即可完成。本节重点介绍环境搭建后如何进行功能验证。"
url: https://www.hikunpeng.com/document/detail/zh/kunpengdevkithistory/devkit_24/probestpractice/kunpengDevKitProPractice_0049.html
sourcePath: /source/zh/kunpengdevkithistory/devkit_24/probestpractice/kunpengDevKitProPractice_0049.html
indexId: d308fb3cafc1ba5045c716efacfbb16c8b557c3b2b5ead9740141f544725a2db92
---
# 运行验证

Kafka安装包在鲲鹏环境安装时，需要依赖bigtop-utils、zookeeper等包，读者在执行本章节验证前，需完成环境搭建工作，在相关的环境依赖具备条件下，kafka的安装只需要通过最普通的RPM包安装命令（rpm -ivh xx.rpm）即可完成。本节重点介绍环境搭建后如何进行功能验证。

- 获取zookeeper包的地址如下：

  - rpm包：https://mirrors.huaweicloud.com/openeuler/openEuler-20.03-LTS-SP4/everything/aarch64/Packages/zookeeper-3.6.1-2.6.oe2003sp4.noarch.rpm
  - tar包：http://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz。
- 获取bigtop包的地址：https://ci.bigtop.apache.org/view/Releases/job/Bigtop-3.2.1-aarch64/DISTRO=centos-7,PLATFORM=aarch64-slave,PRODUCT=bigtop-utils/


#### 操作步骤

1. 安装Kafka。
  切换至终端工具，执行以下命令。

```
cd /opt/DevKit/workspace/devadmin/porting/report/packagerebuild/ && ll
```


  此路径下有一个以软件包重构任务名称生成的目录，如：Package_Rebuild_Task3，切换到此目录下，执行以下命令：

```
rpm -ivh kafka-2.4.1-1.el7.aarch64.rpm
```


  Package_Rebuild_Task3为重构后的软件包存放的目录，此路径可以从重构成功后的右下角弹窗中显示的软件包存放路径获取。

  安装回显信息如下：

```
[root@localhost]# rpm -ivh kafka-2.4.1-1.el7.aarch64.rpm
Verifying...          ################################# [100%]
Preparing...          ################################# [100%]
Updating / installing...
1:kafka-2.4.1-1.el7.aarch64        ################################# [100%]
```


2. 启动zookeeper。
  执行以下命令启动zookeeper。

```
cd /usr/lib/zookeeper/bin/
./zkServer.sh start
```

图1 zookeeper启动成功


  若是dnf或rpm方式安装的zookeeper，默认在“/opt”目录下，需将“/opt/zookeeper/lib”下的两个jar包复制到kafka的libs目录下，才可以正常启动kafka。 zookeeper-3.6.2.jar zookeeper-jute-3.6.2.jar

3. 启动Kafka。
  执行以下命令启动Kafka

```
cd /usr/lib/kafka/bin
./kafka-server-start.sh ../config/server.properties
```


  图2 启动Kafka

  启动成功后，不可关闭该终端窗口。

4. 功能验证。
采用命令行方式进行功能验证。

  a. 执行以下命令，创建主题（新打开一个Terminal窗口）。

```
cd /usr/lib/kafka/bin
kafka-topics.sh --zookeeper localhost:2181 --create --topic sandbox-experiment --partitions 2 --replication-factor 1
```


  b. 执行以下命令启动消费者服务。

```
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sandbox-experiment
```


  c. 执行以下命令启动生产者服务（新打开一个Terminal窗口）。

```
kafka-console-producer.sh --broker-list localhost:9092 --topic sandbox-experiment
```


    发送消息“beginning hello kafka”

    图3 生产者服务发送消息

  d. 消费者服务收到消息。
    图4 消费者服务收到消息

    证明重构后的kafka-2.4.1-1.el7.aarch.rpm软件包，在鲲鹏服务器上可正常安装使用。