
# 调测Kafka SpringBoot样例程序
本章节适用于MRS 3.3.0及之后版本。
"kafka-springboot-examples"样例代码，JDK版本支持JDK 8、JDK 17。
1. 开启Kafka Plain认证。 
   登录FusionInsight Manager页面，选择"集群 \> 服务 \> Kafka \> 配置 \> 全部配置"，搜索参数"sasl.enabled.mechanisms"，将参数值改为"GSSAPI,PLAIN"。单击"保存"，单击"概览"，选择"更多 \> 重启服务"使配置生效
   
   
2. 获取"huawei-spring-boot-kafka-examples-\*.jar"。 
   在样例代码的"springboot/kafka-examples"目录下找到pom文件，在此文件同级目录使用maven install工具编译SpringBoot样例，此时会生成一个target文件夹，在target文件夹中得到"huawei-spring-boot-kafka-examples-\*.jar"。
   
   
3. 在Windows或Linux上创建一个目录作为运行目录。 
   - 在Windows创建路径"D:\\Spring", 将"huawei-spring-boot-kafka-examples-\*.jar"和application.properties上传到当前路径下面。
   
   - 在Linux上创建路径"/opt/spring"，将"huawei-spring-boot-kafka-examples-\*.jar"和application.properties上传到当前路径下面。
   
   
   
   
4. 执行命令启动SpringBoot。 
   - Windows环境下在目录"D:\\Spring"打开Windows cmd工具执行： **java -jar huawei-spring-boot-kafka-examples-2.8.1-SNAPSHOT.jar**
     
   
   - Linux环境下在目录"/opt/spring"下执行： **java -jar huawei-spring-boot-kafka-examples-2.8.1-SNAPSHOT.jar**
     
   
   
   
   
5. 生产数据。 
   - Windows环境下在浏览器中访问链接：http://*SpringBoot启动时绑定的IP地址* :*SpringBoot启动时绑定的端口* /produce，生产数据到Broker。结果如下：
     图1生产数据   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001693995732.png "点击放大") 
   
   - Linux环境下通过执行**curl** 命令访问SpringBoot。
     **curl http://** *SpringBoot启动时绑定的IP地址* **:** *SpringBoot启动时绑定的端口* **/produce**
     
   
   
   
   
6. 消费数据。 
   - Windows环境下在浏览器中访问链接：http://*SpringBoot启动时绑定的IP地址* :*SpringBoot启动时绑定的端口* /consume，从Broker消费数据。结果如下：
     图2消费数据   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001693836232.png "点击放大") 
   
   - Linux环境下通过执行**curl** 命令访问SpringBoot。
     **curl http://** *SpringBoot启动时绑定的IP地址* **:** *SpringBoot启动时绑定的端口* **/consume**
     
   
   
   
   
 
