运行验证

操作步骤

1. 安装Kafka。

   切换至终端工具，执行以下命令。

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

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

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

   

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

   安装回显信息如下：

   1 2 3 4 5

   [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。

   1 2	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

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

   图2 启动Kafka
   
   

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

4. 功能验证。

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

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

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

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

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

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

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

      发送消息“beginning hello kafka”

      图3 生产者服务发送消息
      
   4. 消费者服务收到消息。
      图4 消费者服务收到消息
      

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